Skip to content

Commit f001b27

Browse files
committed
Change strategy to Once
1 parent 69be17b commit f001b27

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/SparkOptimizer.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,9 @@ class SparkOptimizer(
4444
Batch("PartitionPruning", Once,
4545
PartitionPruning,
4646
OptimizeSubqueries) :+
47-
Batch("Pushdown and infer Filters from PartitionPruning", fixedPoint,
48-
PushDownPredicates,
47+
Batch("Pushdown Filters from PartitionPruning", fixedPoint,
48+
PushDownPredicates) :+
49+
Batch("Infer Filters from DynamicPruning", Once,
4950
InferFiltersFromConstraints) :+
5051
Batch("Cleanup filters that cannot be pushed down", Once,
5152
CleanupDynamicPruningFilters,

0 commit comments

Comments
 (0)