diff --git a/be/src/runtime/exec_env_init.cpp b/be/src/runtime/exec_env_init.cpp index 4c3c6165857e57b..f03ca9a6593220c 100644 --- a/be/src/runtime/exec_env_init.cpp +++ b/be/src/runtime/exec_env_init.cpp @@ -735,6 +735,7 @@ void ExecEnv::destroy() { SAFE_STOP(_runtime_filter_timer_queue); // NewLoadStreamMgr should be destoried before storage_engine & after fragment_mgr stopped. _new_load_stream_mgr.reset(); + _load_stream_mgr.reset(); _stream_load_executor.reset(); _memtable_memory_limiter.reset(); _delta_writer_v2_pool.reset();