[fix](pipelineX) _local_channel_dependency is null in non pipelineX (#32054)

2024-03-11 18:20:04 +08:00
parent a7a85dd330
commit 68a5319da3
1 changed files with 1 additions and 1 deletions
--- a/be/src/vec/runtime/vdata_stream_recvr.cpp
+++ b/be/src/vec/runtime/vdata_stream_recvr.cpp
@ -487,7 +487,7 @@ void VDataStreamRecvr::cancel_stream(Status exec_status) {

 void VDataStreamRecvr::SenderQueue::update_blocks_memory_usage(int64_t size) {
    _recvr->update_blocks_memory_usage(size);
-    if (_recvr->exceeds_limit(0)) {
+    if (_local_channel_dependency && _recvr->exceeds_limit(0)) {
        _local_channel_dependency->block();
    }
 }