diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorCoalesce.java ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorCoalesce.java index 3a560ca..c66beb0 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorCoalesce.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/VectorCoalesce.java @@ -225,9 +225,14 @@ public void evaluate(VectorizedRowBatch batch) { // NULL out the remaining columns. outputColVector.noNulls = false; - for (int i = 0; i < unassignedColumnCount; i++) { - final int batchIndex = unassignedBatchIndices[i]; - outputIsNull[batchIndex] = true; + if (isAllUnassigned) { + outputIsNull[0] = true; + outputColVector.isRepeating = true; + } else { + for (int i = 0; i < unassignedColumnCount; i++) { + final int batchIndex = unassignedBatchIndices[i]; + outputIsNull[batchIndex] = true; + } } }