Github user paul-rogers commented on a diff in the pull request: https://github.com/apache/drill/pull/1059#discussion_r155939354 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/union/UnionAllRecordBatch.java --- @@ -97,6 +97,14 @@ protected void buildSchema() throws SchemaChangeException { VectorAccessibleUtilities.setValueCount(container,0); } + @Override + protected boolean checkForEarlyFinish() { + if (leftUpstream == IterOutcome.NONE && rightUpstream == IterOutcome.NONE) { + return true; + } + return false; --- End diff -- Convert to return of boolean expression?
---