diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/RuntimeFilterVisitor.java | 12 |
1 files changed, 2 insertions, 10 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/RuntimeFilterVisitor.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/RuntimeFilterVisitor.java index bfba5f2c1..fcfa2bca1 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/RuntimeFilterVisitor.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/physical/visitor/RuntimeFilterVisitor.java @@ -222,18 +222,10 @@ public class RuntimeFilterVisitor extends BasePrelVisitor<Prel, Void, RuntimeExc holder.setFromBuildSide(true); right.accept(this, holder); boolean routeToForeman = holder.needToRouteToForeman(); - if (!routeToForeman) { - runtimeFilterDef.setSendToForeman(false); - } else { - runtimeFilterDef.setSendToForeman(true); - } + runtimeFilterDef.setSendToForeman(routeToForeman); List<BloomFilterDef> bloomFilterDefs = runtimeFilterDef.getBloomFilterDefs(); for (BloomFilterDef bloomFilterDef : bloomFilterDefs) { - if (!routeToForeman) { - bloomFilterDef.setLocal(true); - } else { - bloomFilterDef.setLocal(false); - } + bloomFilterDef.setLocal(!routeToForeman); } } } |