Github user paul-rogers commented on a diff in the pull request: https://github.com/apache/drill/pull/1059#discussion_r155938557 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinBatch.java --- @@ -535,4 +537,25 @@ public void close() { } super.close(); } + + @Override + protected boolean checkForEarlyFinish() { + if (joinType == JoinRelType.INNER && + (leftUpstream == IterOutcome.NONE || rightUpstream == IterOutcome.NONE) || + joinType != JoinRelType.INNER && + (leftUpstream == IterOutcome.NONE && rightUpstream == IterOutcome.NONE)) { + return true; + } + return false; --- End diff -- See below. The if statement can be omitted.
---