fix deadbuf issue when flushing an outgoing batch
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/a136a5bf Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/a136a5bf Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/a136a5bf Branch: refs/heads/master Commit: a136a5bf53f87ac256d311fbbe6f1a373d193b1f Parents: 8ffc674 Author: Ben Becker <[email protected]> Authored: Sat Aug 10 01:29:39 2013 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Thu Aug 15 18:31:31 2013 -0700 ---------------------------------------------------------------------- .../exec/physical/impl/partitionsender/OutgoingRecordBatch.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a136a5bf/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java index b40ce4c..6847e5a 100644 --- a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java +++ b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java @@ -98,7 +98,7 @@ public class OutgoingRecordBatch implements RecordBatch { for (VectorWrapper v : vectorContainer) { logger.debug("Reallocating vv to capacity " + recordCapacity + " after flush. " + v.getValueVector()); getAllocator(v.getValueVector(), - TypeHelper.getNewVector(v.getField(), context.getAllocator())).alloc(recordCapacity); + v.getValueVector()).alloc(recordCapacity); } if (!ok) { throw new SchemaChangeException("Flush ended NOT OK!"); } }
