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();