From d63dfa470be190a340d4d0bc1e2db091251a9355 Mon Sep 17 00:00:00 2001 From: Yongqiang YANG Date: Tue, 16 Jul 2024 00:18:09 +0800 Subject: [PATCH] fix --- be/src/cloud/cloud_stream_load_executor.cpp | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/be/src/cloud/cloud_stream_load_executor.cpp b/be/src/cloud/cloud_stream_load_executor.cpp index 338668aab322cc..1b8167c96ebd48 100644 --- a/be/src/cloud/cloud_stream_load_executor.cpp +++ b/be/src/cloud/cloud_stream_load_executor.cpp @@ -63,8 +63,7 @@ Status CloudStreamLoadExecutor::operate_txn_2pc(StreamLoadContext* ctx) { if (!config::enable_stream_load_commit_txn_on_be) { VLOG_DEBUG << "2pc commit stream load txn with FE support: " << op_info; st = StreamLoadExecutor::operate_txn_2pc(ctx); - } - if (topt == TxnOpParamType::WITH_TXN_ID) { + } else if (topt == TxnOpParamType::WITH_TXN_ID) { VLOG_DEBUG << "2pc commit stream load txn directly: " << op_info; st = _exec_env->storage_engine().to_cloud().meta_mgr().commit_txn(*ctx, true); } else if (topt == TxnOpParamType::WITH_LABEL) {