diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/CastStringGroupToString.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/CastStringGroupToString.java index bbc770c..7bb2f8b 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/CastStringGroupToString.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/CastStringGroupToString.java @@ -35,6 +35,6 @@ public CastStringGroupToString(int inputColumn, int outputColumn) { @Override protected void func(BytesColumnVector outV, byte[][] vector, int[] start, int[] length, int i) { - outV.setVal(i, vector[i], start[i], length[i]); + outV.setRef(i, vector[i], start[i], length[i]); } }