fix

apache · Mar 29, 2024 · b299cc6 · b299cc6
1 parent ba90c28
commit b299cc6
Showing 1 changed file with 1 addition and 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
@@ -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) {