mymeiyi commented on code in PR #31017:
URL: https://github.com/apache/doris/pull/31017#discussion_r1494069859


##########
be/src/vec/sink/group_commit_block_sink.cpp:
##########
@@ -141,12 +144,9 @@ Status GroupCommitBlockSink::send(RuntimeState* state, 
vectorized::Block* input_
         return status;
     }
     SCOPED_TIMER(_profile->total_time_counter());
-    // update incrementally so that FE can get the progress.
-    // the real 'num_rows_load_total' will be set when sink being closed.
-    state->update_num_rows_load_total(rows);

Review Comment:
   the stream load row count is error if remove this line?



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to