Skip to content

Commit

Permalink
[Bug](pipeline) fix pipeline task execute without wait second start rpc
Browse files Browse the repository at this point in the history
  • Loading branch information
zhangstar333 committed Jan 31, 2024
1 parent 9a24e70 commit 08e4f98
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions be/src/pipeline/pipeline_task.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -230,6 +230,10 @@ Status PipelineTask::execute(bool* eos) {
// The status must be runnable
*eos = false;
if (!_opened) {
if (has_dependency()) {
set_state(PipelineTaskState::BLOCKED_FOR_DEPENDENCY);
return Status::OK();
}
{
SCOPED_RAW_TIMER(&time_spent);
auto st = _open();
Expand All @@ -242,10 +246,6 @@ Status PipelineTask::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();
Expand Down Expand Up @@ -297,7 +297,7 @@ Status PipelineTask::execute(bool* eos) {
}
}
}
if (*eos) { // now only join node have add_dependency, and join probe could start when the join sink is eos
if (*eos) { // now only join node/set operation node have add_dependency, and join probe could start when the join sink is eos
_finish_p_dependency();
}

Expand Down

0 comments on commit 08e4f98

Please sign in to comment.