From 9502cc758d0fcecaa51ba3ccc264cbce83aaf1d9 Mon Sep 17 00:00:00 2001 From: meiyi Date: Wed, 8 Nov 2023 11:57:07 +0800 Subject: [PATCH] [fix](regression) fix group commit regression test (#26557) --- be/src/service/internal_service.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/be/src/service/internal_service.cpp b/be/src/service/internal_service.cpp index 52b448a5f6..01151dcf34 100644 --- a/be/src/service/internal_service.cpp +++ b/be/src/service/internal_service.cpp @@ -1849,9 +1849,10 @@ void PInternalServiceImpl::group_commit_insert(google::protobuf::RpcController* } } st.to_protobuf(response->mutable_status()); + _exec_env->new_load_stream_mgr()->remove(load_id); }); - _exec_env->new_load_stream_mgr()->remove(load_id); if (!ret) { + _exec_env->new_load_stream_mgr()->remove(load_id); offer_failed(response, done, _light_work_pool); return; }