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(); + } }