Github user vrozov commented on a diff in the pull request: https://github.com/apache/drill/pull/1025#discussion_r150326663 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/mergereceiver/MergingRecordBatch.java --- @@ -177,11 +177,11 @@ public IterOutcome innerNext() { } boolean schemaChanged = false; - if (prevBatchWasFull) { + if (!prevBatchNotFull) { --- End diff -- @amansinha100 Addressed minor comment, please review delta and I'll squash it.
---