diff options
| author | Salim Achouche <sachouche2@gmail.com> | 2018-04-22 18:02:35 -0700 |
|---|---|---|
| committer | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2018-05-19 22:33:00 +0300 |
| commit | dc1db98f613f041e40c2c704862051ee2a51734a (patch) | |
| tree | f09cde1c7e8706d70d2d0ff86d9097de4c5c1107 /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java | |
| parent | f4f4dc54520e33f0b880334ff97a8a55078e9d1c (diff) | |
DRILL-6348: Received batches are now owned by the receive operators instead of the parent
closes #1237
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java index 0ef84b960..66a0cc2c2 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java @@ -42,7 +42,7 @@ public class MergingReceiverCreator implements BatchCreator<MergingReceiverPOP> IncomingBuffers bufHolder = context.getBuffers(); assert bufHolder != null : "IncomingBuffers must be defined for any place a receiver is declared."; - RawBatchBuffer[] buffers = bufHolder.getBuffers(receiver.getOppositeMajorFragmentId()); + RawBatchBuffer[] buffers = bufHolder.getCollector(receiver.getOppositeMajorFragmentId()).getBuffers(); return new MergingRecordBatch(context, receiver, buffers); } |