Check case insensitive

Kimahriman · Dec 19, 2024 · c3062e1 · c3062e1
1 parent 573016a
commit c3062e1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala
@@ -72,7 +72,7 @@ class FileStreamSource(
   private val optionsForInnerDataSource = sourceOptions.optionMapWithoutPath ++ {
     val pathOption =
       if (!SparkHadoopUtil.get.isGlobPath(new Path(path)) && options.contains("path") &&
-          !options.contains(FileIndexOptions.BASE_PATH_PARAM)) {
+          !CaseInsensitiveMap(options).contains(FileIndexOptions.BASE_PATH_PARAM)) {
         Map(FileIndexOptions.BASE_PATH_PARAM -> path)
       } else {
         Map()