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 06f4aafe7c8 [fix](pipeline) The sink operator should not be set to
ready when closing the source operator (#48008)
06f4aafe7c8 is described below
commit 06f4aafe7c85d4640e5546fcc64a5cae50ab4bfc
Author: Jerry Hu <hushengg...@selectdb.com>
AuthorDate: Tue Feb 18 21:03:43 2025 +0800
[fix](pipeline) The sink operator should not be set to ready when closing
the source operator (#48008)
---
be/src/pipeline/exec/operator.cpp | 5 -----
1 file changed, 5 deletions(-)
diff --git a/be/src/pipeline/exec/operator.cpp
b/be/src/pipeline/exec/operator.cpp
index 44199114f68..dca901cd0f1 100644
--- a/be/src/pipeline/exec/operator.cpp
+++ b/be/src/pipeline/exec/operator.cpp
@@ -513,11 +513,6 @@ Status
PipelineXLocalState<SharedStateArg>::close(RuntimeState* state) {
COUNTER_SET(_wait_for_dependency_timer,
_dependency->watcher_elapse_time());
}
_closed = true;
- // Some kinds of source operators has a 1-1 relationship with a sink
operator (such as AnalyticOperator).
- // We must ensure AnalyticSinkOperator will not be blocked if
AnalyticSourceOperator already closed.
- if (_shared_state && _shared_state->sink_deps.size() == 1) {
- _shared_state->sink_deps.front()->set_always_ready();
- }
return Status::OK();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
