diff --git a/plugins/data-migration/src/main/java/org/opengauss/admin/plugin/service/impl/MigrationTaskServiceImpl.java b/plugins/data-migration/src/main/java/org/opengauss/admin/plugin/service/impl/MigrationTaskServiceImpl.java
index 18f600230d4ab41ada195a94743f8026c399a052..574084bcca283b965a86f2f6a5db64d8dd9ec583 100644
--- a/plugins/data-migration/src/main/java/org/opengauss/admin/plugin/service/impl/MigrationTaskServiceImpl.java
+++ b/plugins/data-migration/src/main/java/org/opengauss/admin/plugin/service/impl/MigrationTaskServiceImpl.java
@@ -403,13 +403,8 @@ public class MigrationTaskServiceImpl extends ServiceImpl<MigrationTaskMapper, M
             } else {
                 log.debug("task status {} : {}", t.getId(), state);
             }
-            if (state > t.getExecStatus()) {
+            if (t.getExecStatus() < TaskStatus.MIGRATION_FINISH.getCode()) {
                 update.setExecStatus(state);
-            } else if (Objects.equals(t.getExecStatus(), TaskStatus.INCREMENTAL_PAUSE.getCode()) || Objects.equals(
-                t.getExecStatus(), TaskStatus.REVERSE_PAUSE.getCode())) {
-                update.setExecStatus(state);
-            } else {
-                log.debug("task status {} : {} no update", t.getId(), state);
             }
 
             if (TaskStatus.FULL_CHECK_FINISH.getCode().equals(state) && t.getMigrationModelId().equals(1)) {