remove the case sensitivity handling

apache · Mar 22, 2021 · 30d2d8b · 30d2d8b
1 parent 241e6e4
commit 30d2d8b
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileScan.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileScan.scala
@@ -86,10 +86,9 @@ trait FileScan extends Scan
   protected def seqToString(seq: Seq[Any]): String = seq.mkString("[", ", ", "]")
 
   private lazy val (normalizedPartitionFilters, normalizedDataFilters) = {
-    val output = readSchema().toAttributes.map(a => a.withName(normalizeName(a.name)))
-    val partitionFilterAttributes =
-      AttributeSet(partitionFilters).map(a => normalizeName(a.name) -> a).toMap
-    val dataFiltersAttributes = AttributeSet(dataFilters).map(a => normalizeName(a.name) -> a).toMap
+    val output = readSchema().toAttributes
+    val partitionFilterAttributes = AttributeSet(partitionFilters).map(a => a.name -> a).toMap
+    val dataFiltersAttributes = AttributeSet(dataFilters).map(a => a.name -> a).toMap
     val normalizedPartitionFilters = ExpressionSet(partitionFilters.map(
       QueryPlan.normalizeExpressions(_,
         output.map(a => partitionFilterAttributes.getOrElse(a.name, a)))))