This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 647a0606aa695fd75a017a2a0b5c1bfc2b9965a2 Author: Gabriel <[email protected]> AuthorDate: Fri Mar 22 10:07:49 2024 +0800 [pipelineX](refactor) Wait for 2-phase execution before opening (#32613) Wait for 2-phase execution before opening --- be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/be/src/pipeline/pipeline_x/pipeline_x_task.cpp b/be/src/pipeline/pipeline_x/pipeline_x_task.cpp index 2b7a67a2005..689c4e672e6 100644 --- a/be/src/pipeline/pipeline_x/pipeline_x_task.cpp +++ b/be/src/pipeline/pipeline_x/pipeline_x_task.cpp @@ -225,6 +225,10 @@ Status PipelineXTask::execute(bool* eos) { } }}; *eos = false; + if (has_dependency()) { + set_state(PipelineTaskState::BLOCKED_FOR_DEPENDENCY); + return Status::OK(); + } // The status must be runnable if (!_opened) { { @@ -235,10 +239,6 @@ Status PipelineXTask::execute(bool* eos) { } RETURN_IF_ERROR(st); } - if (has_dependency()) { - set_state(PipelineTaskState::BLOCKED_FOR_DEPENDENCY); - return Status::OK(); - } if (!source_can_read()) { set_state(PipelineTaskState::BLOCKED_FOR_SOURCE); return Status::OK(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
