in partition sender, on Iteroutcome.STOP, cleanup without flushing
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/e28e1ef3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/e28e1ef3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/e28e1ef3 Branch: refs/heads/master Commit: e28e1ef346b2e29862fb760be973c9145b55b761 Parents: bf3fa66 Author: Steven Phillips <[email protected]> Authored: Mon Mar 31 17:47:56 2014 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Sat Apr 19 18:07:09 2014 -0700 ---------------------------------------------------------------------- .../impl/partitionsender/PartitionSenderRootExec.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/e28e1ef3/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java index 19fe98b..d0efcb0 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java @@ -95,7 +95,6 @@ public class PartitionSenderRootExec implements RootExec { logger.debug("Partitioner.next(): got next record batch with status {}", out); switch(out){ case NONE: - case STOP: try { // send any pending batches for (OutgoingRecordBatch batch : outgoing) { @@ -109,6 +108,12 @@ public class PartitionSenderRootExec implements RootExec { } return false; + case STOP: + for (OutgoingRecordBatch batch : outgoing) { + batch.clear(); + } + return false; + case OK_NEW_SCHEMA: try { // send all existing batches
