diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java
index 7b78efc7a50cd5..a9bda01c3e4183 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java
@@ -231,6 +231,8 @@ public void onTaskFailed(long taskId, FailMsg failMsg) {
                 idToTasks.remove(loadTask.getSignature());
                 if (loadTask instanceof LoadLoadingTask) {
                     loadStatistic.removeLoad(((LoadLoadingTask) loadTask).getLoadId());
+                    // restore load progress
+                    Env.getCurrentProgressManager().registerProgressSimple(String.valueOf(id));
                 }
                 loadTask.updateRetryInfo();
                 idToTasks.put(loadTask.getSignature(), loadTask);