This is an automated email from the ASF dual-hosted git repository.
mrhhsg pushed a commit to branch spill_and_reserve
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/spill_and_reserve by this push:
new 1984506b6cd [fix] ExchangeSourceOperator consumes a large amount of
memory.
1984506b6cd is described below
commit 1984506b6cd9f24deab38de89824d89121c838bd
Author: Hu Shenggang <hushengg...@selectdb.com>
AuthorDate: Tue Jan 14 14:08:22 2025 +0800
[fix] ExchangeSourceOperator consumes a large amount of memory.
---
be/src/pipeline/exec/exchange_sink_operator.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/exec/exchange_sink_operator.cpp
b/be/src/pipeline/exec/exchange_sink_operator.cpp
index 864f50c8ae0..3ac73813021 100644
--- a/be/src/pipeline/exec/exchange_sink_operator.cpp
+++ b/be/src/pipeline/exec/exchange_sink_operator.cpp
@@ -223,7 +223,7 @@ Status ExchangeSinkLocalState::open(RuntimeState* state) {
_parent->operator_id(), _parent->node_id(),
"BroadcastDependency", true);
_broadcast_pb_mem_limiter =
vectorized::BroadcastPBlockHolderMemLimiter::create_shared(_broadcast_dependency);
- } else if (!only_local_exchange) {
+ } else if (_last_local_channel_idx > -1) {
size_t dep_id = 0;
for (auto& channel : channels) {
if (channel->is_local()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
