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

commit 68a5319da366aa7495e9caa8efaff2c9ed2aaf81
Author: Mryange <59914473+mrya...@users.noreply.github.com>
AuthorDate: Mon Mar 11 18:20:04 2024 +0800

    [fix](pipelineX) _local_channel_dependency is null in non pipelineX (#32054)
---
 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 9708be6bde9..0bef6b6eaab 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();
     }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to