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 7819c75e55a [fix](shuffle) Fix local exchange dependency blocking
(#38160)
7819c75e55a is described below
commit 7819c75e55adb567e10cd8b88ad50915350050ac
Author: Gabriel <[email protected]>
AuthorDate: Sat Jul 20 00:19:47 2024 +0800
[fix](shuffle) Fix local exchange dependency blocking (#38160)
## Proposed changes
pick #38151
<!--Describe your changes.-->
---
be/src/vec/runtime/vdata_stream_recvr.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/vec/runtime/vdata_stream_recvr.cpp
b/be/src/vec/runtime/vdata_stream_recvr.cpp
index 916d874c02e..ac90e277080 100644
--- a/be/src/vec/runtime/vdata_stream_recvr.cpp
+++ b/be/src/vec/runtime/vdata_stream_recvr.cpp
@@ -502,7 +502,7 @@ void VDataStreamRecvr::close() {
}
_is_closed = true;
for (auto& it : _sender_to_local_channel_dependency) {
- it->set_ready();
+ it->set_always_ready();
}
for (int i = 0; i < _sender_queues.size(); ++i) {
_sender_queues[i]->close();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
