From 143e708ec86db670ac517bb810f28fc1efd1b6ea Mon Sep 17 00:00:00 2001
From: liaoxin <liaoxinbit@126.com>
Date: Mon, 11 Mar 2024 13:08:02 +0000
Subject: [PATCH] [fix](merge-cloud) fix LabelAlreayUsedException for broker
 load when fe restart

---
 .../org/apache/doris/cloud/load/CloudBrokerLoadJob.java  | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/cloud/load/CloudBrokerLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/cloud/load/CloudBrokerLoadJob.java
index 9fae8697b52b39..9cf147e019f0c0 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/cloud/load/CloudBrokerLoadJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/load/CloudBrokerLoadJob.java
@@ -118,4 +118,13 @@ brokerFileGroups, getDeadlineMs(), getExecMemLimit(),
         }
         return task;
     }
+
+    @Override
+    protected void executeFinish() {
+        super.executeFinish();
+        // When replaying a load job, the state of the job can be obtained through replaying transaction 
+        // status information in local mode. However, in cloud mode, there is no edit log of transaction 
+        // in fe. so pint an edit log to save the status information of the job here.
+        logFinalOperation();
+    }
 }