fix

dataroaring · Jul 15, 2024 · 3d59754 · 3d59754
1 parent 9188f28
commit 3d59754
Showing 1 changed file with 2 additions and 9 deletions.
diff --git 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) {