Skip to content

Commit 7819c75

Browse files
authored
[fix](shuffle) Fix local exchange dependency blocking (#38160)
## Proposed changes pick #38151 <!--Describe your changes.-->
1 parent 947d759 commit 7819c75

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

be/src/vec/runtime/vdata_stream_recvr.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -502,7 +502,7 @@ void VDataStreamRecvr::close() {
502502
}
503503
_is_closed = true;
504504
for (auto& it : _sender_to_local_channel_dependency) {
505-
it->set_ready();
505+
it->set_always_ready();
506506
}
507507
for (int i = 0; i < _sender_queues.size(); ++i) {
508508
_sender_queues[i]->close();

0 commit comments

Comments
 (0)