From 02d3e5eb9bf8c6b407c67e9c0e64baab7b2a08dc Mon Sep 17 00:00:00 2001 From: Yongqiang YANG Date: Tue, 16 Jul 2024 00:12:33 +0800 Subject: [PATCH] fix --- be/src/cloud/cloud_stream_load_executor.cpp | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/be/src/cloud/cloud_stream_load_executor.cpp b/be/src/cloud/cloud_stream_load_executor.cpp index 8a0fc03cc3a744..338668aab322cc 100644 --- a/be/src/cloud/cloud_stream_load_executor.cpp +++ b/be/src/cloud/cloud_stream_load_executor.cpp @@ -97,16 +97,9 @@ Status CloudStreamLoadExecutor::operate_txn_2pc(StreamLoadContext* ctx) { } Status CloudStreamLoadExecutor::commit_txn(StreamLoadContext* ctx) { - if (!config::enable_stream_load_commit_txn_on_be) { - VLOG_DEBUG << "commit stream load txn with FE support"; - return StreamLoadExecutor::commit_txn(ctx); - } - if (ctx->load_type == TLoadType::ROUTINE_LOAD) { - return StreamLoadExecutor::commit_txn(ctx); - } - // forward to fe to excute commit transaction for MoW table - if (ctx->is_mow_table()) { + if (ctx->is_mow_table() || !config::enable_stream_load_commit_txn_on_be || + ctx->load_type == TLoadType::ROUTINE_LOAD) { Status st; int retry_times = 0; while (retry_times < config::mow_stream_load_commit_retry_times) {