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 <[email protected]> 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 <[email protected]> --- 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: [email protected] For additional commands, e-mail: [email protected]
