diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedRowBatchCtx.java ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedRowBatchCtx.java index ebffbc1a06..306b1b353e 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedRowBatchCtx.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedRowBatchCtx.java @@ -569,7 +569,7 @@ public void addPartitionColsToBatch(ColumnVector[] cols, Object[] partitionValue case CHAR: case VARCHAR: { BytesColumnVector bcv = (BytesColumnVector) cols[colIndex]; - String sVal = value.toString(); + String sVal = value == null ? null : value.toString(); if (sVal == null) { bcv.noNulls = false; bcv.isNull[0] = true;