Github user HanumathRao commented on a diff in the pull request: https://github.com/apache/drill/pull/1237#discussion_r183886561 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/unorderedreceiver/UnorderedReceiverBatch.java --- @@ -182,13 +184,18 @@ public IterOutcome next() { return IterOutcome.OUT_OF_MEMORY; } + // Transfer the ownership of this raw-batch to this operator for proper memory statistics reporting + batch = batch.transferBodyOwnership(oContext.getAllocator()); --- End diff -- @sachouche Thank you for the changes. I was just contemplating if the below change batch = batch.transferBodyOwnership(oContext.getAllocator()); needs to be moved before the check at line number 183.
---