[BugFix] Fix be crash of using closure that already released (backport …

…StarRocks#33876) (StarRocks#34512) Co-authored-by: liuyehcf <1559500551@qq.com>
stdpain · Nov 14, 2023 · c8e307d · c8e307d
1 parent 64001a3
commit c8e307d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/be/src/runtime/sender_queue.cpp b/be/src/runtime/sender_queue.cpp
@@ -567,6 +567,7 @@ void DataStreamRecvr::PipelineSenderQueue::clean_buffer_queues() {
                     item.closure->Run();
                 }
             }
+            chunk_queue.clear();
         }
     }
 }