Use non partitioned dynamic filter limits in FTE

trinodb · Jun 14, 2023 · 4dea674 · 4dea674
1 parent 3873ada
commit 4dea674
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java b/core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
@@ -3054,12 +3054,12 @@ public PhysicalOperation visitDynamicFilterSource(DynamicFilterSourceNode node,
                     // In fault-tolerant execution, all tasks need to collect dynamic filters even if the join has
                     // broadcast distribution type because the collection takes place before the remote exchange
                     ImmutableList.of(taskContext::updateDomains),
-                    getDynamicFilteringMaxSizePerOperator(session, true));
+                    getDynamicFilteringMaxSizePerOperator(session, false));
             return createDynamicFilterSourceOperatorFactory(
                     context.getNextOperatorId(),
                     dynamicFilterSourceConsumer,
                     node,
-                    true,
+                    false,
                     false,
                     source,
                     context);

diff --git a/...ests/src/test/java/io/trino/faulttolerant/TestFaultTolerantExecutionDynamicFiltering.java b/...ests/src/test/java/io/trino/faulttolerant/TestFaultTolerantExecutionDynamicFiltering.java
@@ -56,8 +56,8 @@ protected QueryRunner createQueryRunner()
                 })
                 .setExtraProperties(FaultTolerantExecutionConnectorTestHelper.getExtraProperties())
                 // keep limits lower to test edge cases
-                .addExtraProperty("dynamic-filtering.small-partitioned.max-distinct-values-per-driver", "10")
-                .addExtraProperty("dynamic-filtering.small-partitioned.range-row-limit-per-driver", "100")
+                .addExtraProperty("dynamic-filtering.small.max-distinct-values-per-driver", "10")
+                .addExtraProperty("dynamic-filtering.small.range-row-limit-per-driver", "100")
                 .build();
     }