diff --git a/be/src/runtime/exec_env_init.cpp b/be/src/runtime/exec_env_init.cpp index fb14db11f3..e803fd0da9 100644 --- a/be/src/runtime/exec_env_init.cpp +++ b/be/src/runtime/exec_env_init.cpp @@ -411,6 +411,7 @@ void ExecEnv::_destroy() { // info is deconstructed then BE process will core at coordinator back method in fragment mgr. SAFE_DELETE(_master_info); + _new_load_stream_mgr.reset(); _send_batch_thread_pool.reset(nullptr); _buffered_reader_prefetch_thread_pool.reset(nullptr); _send_report_thread_pool.reset(nullptr);