Author: sershe
Date: Thu Jul 24 22:50:32 2014
New Revision: 1613322
URL: http://svn.apache.org/r1613322
Log:
HIVE-7266 : Optimized HashTable with vectorized map-joins results in String
columns extending (Sergey Shelukhin, reviewed by Matt McCline and Jitendra Nath
Pandey)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnAssignFactory.java
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnAssignFactory.java
URL:
http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnAssignFactory.java?rev=1613322&r1=1613321&r2=1613322&view=diff
==============================================================================
---
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnAssignFactory.java
(original)
+++
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnAssignFactory.java
Thu Jul 24 22:50:32 2014
@@ -393,7 +393,7 @@ public class VectorColumnAssignFactory {
else {
BytesWritable bw = (BytesWritable) val;
byte[] bytes = bw.getBytes();
- assignBytes(bytes, 0, bytes.length, destIndex);
+ assignBytes(bytes, 0, bw.getLength(), destIndex);
}
}
}.init(outputBatch, (BytesColumnVector) destCol);
@@ -408,7 +408,7 @@ public class VectorColumnAssignFactory {
else {
Text bw = (Text) val;
byte[] bytes = bw.getBytes();
- assignBytes(bytes, 0, bytes.length, destIndex);
+ assignBytes(bytes, 0, bw.getLength(), destIndex);
}
}
}.init(outputBatch, (BytesColumnVector) destCol);