From 68a5319da366aa7495e9caa8efaff2c9ed2aaf81 Mon Sep 17 00:00:00 2001 From: Mryange <59914473+Mryange@users.noreply.github.com> Date: Mon, 11 Mar 2024 18:20:04 +0800 Subject: [PATCH] [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 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(); } }