File tree Expand file tree Collapse file tree
spark/src/main/scala/org/apache/comet/rules Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -847,7 +847,7 @@ object CometScanRule extends Logging {
847847 val filePath = pathMethod.invoke(dataFile).toString
848848 val uri = new URI (filePath)
849849 val scheme = uri.getScheme
850- if (scheme != null && ! supportedSchemes.contains(scheme)) {
850+ if (scheme == null || ! supportedSchemes.contains(scheme)) {
851851 unsupportedSchemes += scheme
852852 }
853853 } catch {
@@ -889,7 +889,7 @@ object CometScanRule extends Logging {
889889 try {
890890 val deleteUri = new URI (deletePath)
891891 val deleteScheme = deleteUri.getScheme
892- if (deleteScheme != null && ! supportedSchemes.contains(deleteScheme)) {
892+ if (deleteScheme == null || ! supportedSchemes.contains(deleteScheme)) {
893893 unsupportedSchemes += deleteScheme
894894 }
895895 } catch {
You can’t perform that action at this time.
0 commit comments