BiteTheDDDDt commented on code in PR #45207:
URL: https://github.com/apache/doris/pull/45207#discussion_r1886083527
##########
be/src/pipeline/pipeline_task.cpp:
##########
@@ -320,27 +309,31 @@ Status PipelineTask::execute(bool* eos) {
if (_wait_to_start()) {
return Status::OK();
}
- if (_wake_up_by_downstream) {
- _eos = true;
- *eos = true;
- return Status::OK();
- }
+
// The status must be runnable
if (!_opened && !_fragment_context->is_canceled()) {
+ if (_wake_up_early) {
Review Comment:
没有open，下面执行会有问题，像sink之类的，所以得直接退出
这种情况应该是一个pipeline所有instance被其他downstream做了wake_up，这样处理就是直接不走sink eos就结束
--
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
