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 @@ -820,7 +820,7 @@ object CometScanRule extends Logging {
820820 val filePath = pathMethod.invoke(dataFile).toString
821821 val uri = new URI (filePath)
822822 val scheme = uri.getScheme
823- if (scheme != null && ! supportedSchemes.contains(scheme)) {
823+ if (scheme == null || ! supportedSchemes.contains(scheme)) {
824824 unsupportedSchemes += scheme
825825 }
826826 } catch {
@@ -862,7 +862,7 @@ object CometScanRule extends Logging {
862862 try {
863863 val deleteUri = new URI (deletePath)
864864 val deleteScheme = deleteUri.getScheme
865- if (deleteScheme != null && ! supportedSchemes.contains(deleteScheme)) {
865+ if (deleteScheme == null || ! supportedSchemes.contains(deleteScheme)) {
866866 unsupportedSchemes += deleteScheme
867867 }
868868 } catch {
You can’t perform that action at this time.
0 commit comments