From b299cc60a23fafed4d2fecc6388324caddccc24e Mon Sep 17 00:00:00 2001
From: laihui <1353307710@qq.com>
Date: Fri, 29 Mar 2024 16:48:16 +0800
Subject: [PATCH] fix

---
 .../main/java/org/apache/doris/load/loadv2/BrokerLoadJob.java | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadJob.java
index 612b62e7f3a74a0..942dc61814330e7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadJob.java
@@ -354,9 +354,7 @@ private void onLoadingTaskFinished(BrokerLoadingTaskAttachment attachment) {
                     .add("msg", "Load job try to commit txn")
                     .build());
             Env.getCurrentGlobalTransactionMgr().commitTransaction(
-                    dbId, tableList, transactionId, commitInfos,
-                    new LoadJobFinalOperation(id, loadingStatus, progress, loadStartTimestamp,
-                            finishTimestamp, state, failMsg));
+                    dbId, tableList, transactionId, commitInfos, getLoadJobFinalOperation());
             afterLoadingTaskCommitTransaction(tableList);
             afterCommit();
         } catch (UserException e) {