diff --git a/samples/doris-demo/doris-source-demo/src/main/java/org/apache/doris/sdk/DorisReaderExample.java b/samples/doris-demo/doris-source-demo/src/main/java/org/apache/doris/sdk/DorisReaderExample.java index 5c4a5c101b..03bebef58d 100644 --- a/samples/doris-demo/doris-source-demo/src/main/java/org/apache/doris/sdk/DorisReaderExample.java +++ b/samples/doris-demo/doris-source-demo/src/main/java/org/apache/doris/sdk/DorisReaderExample.java @@ -166,7 +166,7 @@ public class DorisReaderExample { if(!eos){ int i = convertArrow(next, selectedColumns); offset += i; - readRowCount += offset; + readRowCount = offset; } } //close