fix bug

cloud-fan · cloud-fan · commit fdc08707e3e1 · 2017-06-12T19:39:50.000+08:00
diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ColumnVector.java b/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ColumnVector.java
@@ -523,7 +523,7 @@ private void throwUnsupportedException(int requiredCapacity, Throwable cause) {
    * size of the written array.
    */
   public void putArrayOffsetAndSize(int rowId, int offset, int size) {
-    long offsetAndSize = (offset << 32) | size;
+    long offsetAndSize = (((long) offset) << 32) | size;
     putLong(rowId, offsetAndSize);
   }
 
diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OnHeapColumnVector.java b/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/OnHeapColumnVector.java
@@ -43,7 +43,7 @@ public final class OnHeapColumnVector extends ColumnVector {
   private byte[] byteData;
   private short[] shortData;
   private int[] intData;
-  // This is not only used to store data for int column vector, but also can store offsets and
+  // This is not only used to store data for long column vector, but also can store offsets and
   // lengths for array column vector.
   private long[] longData;
   private float[] floatData;

Original file line number	Diff line number	Diff line change
`@@ -523,7 +523,7 @@ private void throwUnsupportedException(int requiredCapacity, Throwable cause) {`
`523`	`523`	`* size of the written array.`
`524`	`524`	`*/`
`525`	`525`	`public void putArrayOffsetAndSize(int rowId, int offset, int size) {`
`526`		`- long offsetAndSize = (offset << 32) \| size;`
	`526`	`+ long offsetAndSize = (((long) offset) << 32) \| size;`
`527`	`527`	`putLong(rowId, offsetAndSize);`
`528`	`528`	`}`
`529`	`529`