Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1073#discussion_r157545737
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java
---
@@ -98,10 +100,12 @@ public int metricId() {
public PartitionSenderRootExec(FragmentContext context,
RecordBatch incoming,
- HashPartitionSender operator) throws
OutOfMemoryException {
+ HashPartitionSender operator,
+ boolean closeIncoming) throws
OutOfMemoryException {
--- End diff --
Introduce back constructor without `closeIncoming` argument and call this
constructor from it with `closeIncoming` set to `false`.
---
