in partition sender, release incoming vectors after partitioning
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/d37d9241 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/d37d9241 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/d37d9241 Branch: refs/heads/master Commit: d37d9241e63a0160cd8d03610326c927b60ea1d0 Parents: e28e1ef Author: Steven Phillips <[email protected]> Authored: Mon Mar 31 19:45:10 2014 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Sat Apr 19 18:07:09 2014 -0700 ---------------------------------------------------------------------- .../physical/impl/partitionsender/PartitionSenderRootExec.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/d37d9241/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 d0efcb0..3e3157b 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 @@ -133,6 +133,9 @@ public class PartitionSenderRootExec implements RootExec { } case OK: partitioner.partitionBatch(incoming); + for (VectorWrapper v : incoming) { + v.clear(); + } context.getStats().batchesCompleted.inc(1); context.getStats().recordsCompleted.inc(incoming.getRecordCount()); return true;
