diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/IngestionLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/IngestionLoadJob.java
index 689b5b7a21662e..5af05d6b8231e9 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/IngestionLoadJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/IngestionLoadJob.java
@@ -715,6 +715,7 @@ public void startEtlJob() {
         etlStartTimestamp = System.currentTimeMillis();
         state = JobState.ETL;
         etlStatus = new EtlStatus();
+        unprotectedLogUpdateStateInfo();
     }
 
     private void unprotectedUpdateToLoadingState(EtlStatus etlStatus, Map<String, Long> filePathToSize)