From 5f5262a885e489f69fcef32620ad69627dbe9594 Mon Sep 17 00:00:00 2001 From: zhannngchen <48427519+zhannngchen@users.noreply.github.com> Date: Sun, 23 Jun 2024 18:11:44 +0800 Subject: [PATCH] [fix](cloud-mow) duplicate key occured when StreamLoad commit failed and retry (#36670) ## Proposed changes Issue Number: close #xxx In our stress test environment, we found that for cloud mow table, when stream load commit failed and retry, the StreamLoadContext->commit_infos is cleared, and FE skipped the delete bitmap calculation task and commit success directly, in such case, the delete bitmap is not calculated correctly --- be/src/runtime/stream_load/stream_load_executor.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/runtime/stream_load/stream_load_executor.cpp b/be/src/runtime/stream_load/stream_load_executor.cpp index 051aca3e13044e..d26beb66827597 100644 --- a/be/src/runtime/stream_load/stream_load_executor.cpp +++ b/be/src/runtime/stream_load/stream_load_executor.cpp @@ -294,7 +294,7 @@ void StreamLoadExecutor::get_commit_request(StreamLoadContext* ctx, request.tbl = ctx->table; request.txnId = ctx->txn_id; request.sync = true; - request.commitInfos = std::move(ctx->commit_infos); + request.commitInfos = ctx->commit_infos; request.__isset.commitInfos = true; request.__set_thrift_rpc_timeout_ms(config::txn_commit_rpc_timeout_ms); request.tbls = ctx->table_list;