This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new d6f459903df [opt](pipeline) Distribute data evenly for passthrough
local exchange (#40637)
d6f459903df is described below
commit d6f459903df646f182605fae833429d5b2ff73c0
Author: Gabriel <gabrielleeb...@gmail.com>
AuthorDate: Wed Sep 11 09:58:14 2024 +0800
[opt](pipeline) Distribute data evenly for passthrough local exchange
(#40637)
## Proposed changes
Issue Number: close #xxx
<!--Describe your changes.-->
---
.../pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp | 1 +
1 file changed, 1 insertion(+)
diff --git
a/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
b/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
index bf3e21f5357..78c2761dcc7 100644
--- a/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
+++ b/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
@@ -27,6 +27,7 @@ Status LocalExchangeSinkLocalState::init(RuntimeState* state,
LocalSinkStateInfo
SCOPED_TIMER(_init_timer);
_compute_hash_value_timer = ADD_TIMER(profile(), "ComputeHashValueTime");
_distribute_timer = ADD_TIMER(profile(), "DistributeDataTime");
+ _channel_id = info.task_idx;
return Status::OK();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
