diff --git a/fe/be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute/MaxComputeJniScanner.java b/fe/be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute/MaxComputeJniScanner.java index 515ef8f401b0406..113ed46368b5049 100644 --- a/fe/be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute/MaxComputeJniScanner.java +++ b/fe/be-java-extensions/max-compute-scanner/src/main/java/org/apache/doris/maxcompute/MaxComputeJniScanner.java @@ -301,6 +301,7 @@ private int readVectors(int expectedRows) throws IOException { columnValue.reset(column); batchRows = column.getValueCount(); for (int j = 0; j < batchRows; j++) { + columnValue.setColumnIdx(j); appendData(readColumnId, columnValue); } }