[doris] 45/47: [bugfix](stream receiver) be will core during stop because receiver is not closed (#25298)

[kx...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit a4bbd132ca095e8d77adc5145865d1d286b14c49
Author: yiguolei <67...@qq.com>
AuthorDate: Wed Oct 11 19:49:40 2023 +0800

    [bugfix](stream receiver) be will core during stop because receiver is not closed (#25298)
    
    Co-authored-by: yiguolei <yi...@gmail.com>
---
 be/src/vec/runtime/vdata_stream_mgr.cpp | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/be/src/vec/runtime/vdata_stream_mgr.cpp b/be/src/vec/runtime/vdata_stream_mgr.cpp
index ad161828f90..35f93e53014 100644
--- a/be/src/vec/runtime/vdata_stream_mgr.cpp
+++ b/be/src/vec/runtime/vdata_stream_mgr.cpp
@@ -39,6 +39,12 @@ VDataStreamMgr::VDataStreamMgr() {
 
 VDataStreamMgr::~VDataStreamMgr() {
     // TODO: metric
+    auto receiver_iterator = _receiver_map.begin();
+    while (receiver_iterator != _receiver_map.end()) {
+        // Has to call close here, because receiver will check if the receiver is closed.
+        // It will core during graceful stop.
+        receiver_iterator->second->close();
+    }
 }
 
 inline uint32_t VDataStreamMgr::get_hash_value(const TUniqueId& fragment_instance_id,


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