This is an automated email from the ASF dual-hosted git repository.
zclll 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 75b711c50db [chore](log) remove unused be warning log (#55159)
75b711c50db is described below
commit 75b711c50dbe541c2097023c7d09ba114cd5d809
Author: Mryange <[email protected]>
AuthorDate: Mon Aug 25 20:19:08 2025 +0800
[chore](log) remove unused be warning log (#55159)
Now this log will often be triggered, because we have done the logic
that the downstream can end early.
---
be/src/pipeline/exec/exchange_sink_operator.cpp | 4 ----
1 file changed, 4 deletions(-)
diff --git a/be/src/pipeline/exec/exchange_sink_operator.cpp
b/be/src/pipeline/exec/exchange_sink_operator.cpp
index 607fc1d1243..d3b8152bd6b 100644
--- a/be/src/pipeline/exec/exchange_sink_operator.cpp
+++ b/be/src/pipeline/exec/exchange_sink_operator.cpp
@@ -215,7 +215,6 @@ Status ExchangeSinkLocalState::open(RuntimeState* state) {
SCOPED_TIMER(_open_timer);
RETURN_IF_ERROR(Base::open(state));
_writer.reset(new Writer());
- auto& p = _parent->cast<ExchangeSinkOperatorX>();
for (int i = 0; i < channels.size(); ++i) {
RETURN_IF_ERROR(channels[i]->open(state));
@@ -236,9 +235,6 @@ Status ExchangeSinkLocalState::open(RuntimeState* state) {
_local_channels_dependency.push_back(dep);
DCHECK(_local_channels_dependency[dep_id] != nullptr);
dep_id++;
- } else {
- LOG(WARNING) << "local recvr is null: query id = "
- << print_id(state->query_id()) << " node id =
" << p.node_id();
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
