File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -172,7 +172,7 @@ case class HiveTableScanExec(
172172 prunePartitions(hivePartitions)
173173 }
174174 } else {
175- if (conf.metastorePartitionPruning &&
175+ if (sparkSession.sessionState. conf.metastorePartitionPruning &&
176176 partitionPruningPred.nonEmpty) {
177177 rawPartitions
178178 } else {
@@ -184,7 +184,7 @@ case class HiveTableScanExec(
184184 // exposed for tests
185185 @ transient lazy val rawPartitions : Seq [HivePartition ] = {
186186 val prunedPartitions =
187- if (conf.metastorePartitionPruning &&
187+ if (sparkSession.sessionState. conf.metastorePartitionPruning &&
188188 partitionPruningPred.nonEmpty) {
189189 // Retrieve the original attributes based on expression ID so that capitalization matches.
190190 val normalizedFilters = partitionPruningPred.map(_.transform {
You can’t perform that action at this time.
0 commit comments