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.---
