From 9647885b958012c1eaf82b0d436cbd2dfeedc6eb Mon Sep 17 00:00:00 2001
From: hui lai <1353307710@qq.com>
Date: Mon, 19 Aug 2024 21:23:59 +0800
Subject: [PATCH] [fix](routine load) should update progress before handle
 transaction state transform (#39311) (#39526)

pick (#39311)

Update progress maybe throw exception, causing offset has been persisted
on edit log or meta service, but the memory data has not been updated.
It will cause repeated consumption.
---
 .../org/apache/doris/load/routineload/KafkaRoutineLoadJob.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/KafkaRoutineLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/KafkaRoutineLoadJob.java
index 22de3ef357..12aab19a4a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/KafkaRoutineLoadJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/KafkaRoutineLoadJob.java
@@ -298,8 +298,8 @@ public class KafkaRoutineLoadJob extends RoutineLoadJob {
 
     @Override
     protected void updateProgress(RLTaskTxnCommitAttachment attachment) throws UserException {
-        super.updateProgress(attachment);
         updateProgressAndOffsetsCache(attachment);
+        super.updateProgress(attachment);
     }
 
     @Override