You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by ja...@apache.org on 2014/04/20 03:18:32 UTC
[24/51] [abbrv] git commit: allocate 100 bytes/record for variable
length in partition sender
allocate 100 bytes/record for variable length in partition sender
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/f48d9988
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/f48d9988
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/f48d9988
Branch: refs/heads/master
Commit: f48d9988f9d77d95fbc89fbdf5e8c06672948568
Parents: f2f889c
Author: Steven Phillips <sp...@maprtech.com>
Authored: Tue Apr 1 11:45:04 2014 -0700
Committer: Jacques Nadeau <ja...@apache.org>
Committed: Sat Apr 19 18:07:10 2014 -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/f48d9988/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java
index 60b395f..cd7e632 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/OutgoingRecordBatch.java
@@ -171,7 +171,7 @@ public class OutgoingRecordBatch implements VectorAccessible {
// allocate a new value vector
ValueVector outgoingVector = TypeHelper.getNewVector(v.getField(), context.getAllocator());
- VectorAllocator.getAllocator(v.getValueVector(), outgoingVector).alloc(recordCapacity);
+ VectorAllocator.getAllocator(outgoingVector, 100).alloc(recordCapacity);
vectorContainer.add(outgoingVector);
logger.debug("Reallocating to cap " + recordCapacity + " because of newly init'd vector : " + v.getValueVector());
}