BiteTheDDDDt commented on code in PR #45207:
URL: https://github.com/apache/doris/pull/45207#discussion_r1883634420
##########
be/src/pipeline/pipeline_task.cpp:
##########
@@ -480,7 +470,10 @@ Status PipelineTask::close(Status exec_status) {
Status s;
{
SCOPED_RAW_TIMER(&close_ns);
- s = _sink->close(_state, exec_status);
+ if (close_sink) {
+ _task_profile->add_info_string("WakeUpEarly", wake_up_early() ?
"true" : "false");
+ s = _sink->close(_state, exec_status);
+ }
for (auto& op : _operators) {
auto tem = op->close(_state);
Review Comment:
我改了一下，现在应该可以重入了，直接return的话会漏统计一些时间
--
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
