revert unnecessary changes

apache · Nov 16, 2020 · 0cc0b42 · 0cc0b42
1 parent bf1e56a
commit 0cc0b42
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTableScanExec.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTableScanExec.scala
@@ -172,7 +172,7 @@ case class HiveTableScanExec(
         prunePartitions(hivePartitions)
       }
     } else {
-      if (conf.metastorePartitionPruning &&
+      if (sparkSession.sessionState.conf.metastorePartitionPruning &&
         partitionPruningPred.nonEmpty) {
         rawPartitions
       } else {
@@ -184,7 +184,7 @@ case class HiveTableScanExec(
   // exposed for tests
   @transient lazy val rawPartitions: Seq[HivePartition] = {
     val prunedPartitions =
-      if (conf.metastorePartitionPruning &&
+      if (sparkSession.sessionState.conf.metastorePartitionPruning &&
         partitionPruningPred.nonEmpty) {
         // Retrieve the original attributes based on expression ID so that capitalization matches.
         val normalizedFilters = partitionPruningPred.map(_.transform {