This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 561032fa5ab [improve](join) remove join probe dependency of wait rf
publish finish #29792
561032fa5ab is described below
commit 561032fa5ab8e2ac6107cba48fc9ab0d93eb8ec8
Author: zhangstar333 <[email protected]>
AuthorDate: Mon Jan 15 10:42:27 2024 +0800
[improve](join) remove join probe dependency of wait rf publish finish
#29792
---
be/src/pipeline/pipeline_task.cpp | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/be/src/pipeline/pipeline_task.cpp
b/be/src/pipeline/pipeline_task.cpp
index 8c7796f326a..d87c477a8db 100644
--- a/be/src/pipeline/pipeline_task.cpp
+++ b/be/src/pipeline/pipeline_task.cpp
@@ -297,6 +297,9 @@ 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
+ _finish_p_dependency();
+ }
return Status::OK();
}
@@ -378,10 +381,6 @@ void PipelineTask::set_state(PipelineTaskState state) {
}
}
- if (state == PipelineTaskState::FINISHED) {
- _finish_p_dependency();
- }
-
_cur_state = state;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
