Remove unused SemiJoinNode

trinodb · Jun 4, 2020 · 72474b9 · 72474b9
1 parent e931227
commit 72474b9
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...o-main/src/main/java/io/prestosql/sql/planner/optimizations/PruneUnreferencedOutputs.java b/...o-main/src/main/java/io/prestosql/sql/planner/optimizations/PruneUnreferencedOutputs.java
@@ -258,6 +258,10 @@ public PlanNode visitJoin(JoinNode node, RewriteContext<Set<Symbol>> context)
         @Override
         public PlanNode visitSemiJoin(SemiJoinNode node, RewriteContext<Set<Symbol>> context)
         {
+            if (!context.get().contains(node.getSemiJoinOutput())) {
+                return context.rewrite(node.getSource(), context.get());
+            }
+
             ImmutableSet.Builder<Symbol> sourceInputsBuilder = ImmutableSet.builder();
             sourceInputsBuilder.addAll(context.get()).add(node.getSourceJoinSymbol());
             if (node.getSourceHashSymbol().isPresent()) {