diff --git a/be/src/vec/runtime/vdata_stream_recvr.cpp b/be/src/vec/runtime/vdata_stream_recvr.cpp
index 9708be6bde..0bef6b6eaa 100644
--- 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();
     }
 }