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 @@ -861,7 +861,7 @@ object CometScanRule extends Logging {
861861 val filePath = pathMethod.invoke(dataFile).toString
862862 val uri = new URI (filePath)
863863 val scheme = uri.getScheme
864- if (scheme != null && ! supportedSchemes.contains(scheme)) {
864+ if (scheme == null || ! supportedSchemes.contains(scheme)) {
865865 unsupportedSchemes += scheme
866866 }
867867 } catch {
@@ -903,7 +903,7 @@ object CometScanRule extends Logging {
903903 try {
904904 val deleteUri = new URI (deletePath)
905905 val deleteScheme = deleteUri.getScheme
906- if (deleteScheme != null && ! supportedSchemes.contains(deleteScheme)) {
906+ if (deleteScheme == null || ! supportedSchemes.contains(deleteScheme)) {
907907 unsupportedSchemes += deleteScheme
908908 }
909909 } catch {
You can’t perform that action at this time.
0 commit comments