From 664bbeb10c8ef3bf8d2e3bbfafe342b8984be0cf Mon Sep 17 00:00:00 2001
From: Gabriel <liwenqiang@selectdb.com>
Date: Wed, 15 Jan 2025 13:53:20 +0800
Subject: [PATCH] =?UTF-8?q?[fix](data=20stream)=20Fix=20dead=20loop=20in?=
 =?UTF-8?q?=20VDataStreamMgr's=20de-constructor=20(=E2=80=A6=20(#47000)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 be/src/vec/runtime/vdata_stream_mgr.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/be/src/vec/runtime/vdata_stream_mgr.cpp b/be/src/vec/runtime/vdata_stream_mgr.cpp
index a620d6bde8..afec071f39 100644
--- a/be/src/vec/runtime/vdata_stream_mgr.cpp
+++ b/be/src/vec/runtime/vdata_stream_mgr.cpp
@@ -46,6 +46,7 @@ VDataStreamMgr::~VDataStreamMgr() {
         // Could not call close directly, because during close method, it will remove itself
         // from the map, and modify the map, it will core.
         receivers.push_back(receiver_iterator->second);
+        receiver_iterator++;
     }
     for (auto iter = receivers.begin(); iter != receivers.end(); ++iter) {
         (*iter)->close();