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);


Reply via email to