[fix](regression) fix group commit regression test (#26557)

2023-11-08 11:57:07 +08:00
parent f8f3bc6a67
commit 9502cc758d
1 changed files with 2 additions and 1 deletions
--- 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;
    }