diff --git a/src/main/java/com/pingcap/tikv/operation/transformer/Cast.java b/src/main/java/com/pingcap/tikv/operation/transformer/Cast.java index acd0c3dd..d5b58543 100644 --- a/src/main/java/com/pingcap/tikv/operation/transformer/Cast.java +++ b/src/main/java/com/pingcap/tikv/operation/transformer/Cast.java @@ -30,7 +30,8 @@ public Cast(DataType type) { public void set(Object value, Row row, int pos) { Object casted; if (value == null) { - row.set(row.fieldCount(), targetDataType, null); + row.set(pos, targetDataType, null); + return; } if (targetDataType instanceof IntegerType) { casted = castToLong(value);