From 2f3207c7e2b25cbc9fcd74791ebeb95201880fa3 Mon Sep 17 00:00:00 2001
From: laihui <1353307710@qq.com>
Date: Tue, 13 Aug 2024 21:00:37 +0800
Subject: [PATCH] should update progress before handle transaction state
 transform

---
 .../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 555ae986873060..7f464f3cbec6fb 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
@@ -336,8 +336,8 @@ private void updateProgressAndOffsetsCache(RLTaskTxnCommitAttachment attachment)
 
     @Override
     protected void updateProgress(RLTaskTxnCommitAttachment attachment) throws UserException {
-        super.updateProgress(attachment);
         updateProgressAndOffsetsCache(attachment);
+        super.updateProgress(attachment);
     }
 
     @Override