yiguolei commented on code in PR #60567:
URL: https://github.com/apache/doris/pull/60567#discussion_r3123634934
##########
be/src/exec/pipeline/pipeline_fragment_context.cpp:
##########
@@ -1956,6 +1956,10 @@ bool PipelineFragmentContext::_close_fragment_instance()
{
collect_realtime_load_channel_profile());
}
+ if (!_need_notify_close) {
+ // all submitted tasks done
+ _query_ctx->update_finished_task_counts(get_total_tasks(),
get_closed_tasks());
Review Comment:
这里也不需要更新total。
total 的数量是构建pipeline fragment context 的时候，去更新query context 里的值。
每个task 结束的时候，能做的操作，就是从query context 里把finished task num + 1
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
