diff --git a/service-api/src/main/java/com/lanyuanxiaoyao/service/api/service/SyncStateService.java b/service-api/src/main/java/com/lanyuanxiaoyao/service/api/service/SyncStateService.java
index 14c5cad..28c4ffa 100644
--- a/service-api/src/main/java/com/lanyuanxiaoyao/service/api/service/SyncStateService.java
+++ b/service-api/src/main/java/com/lanyuanxiaoyao/service/api/service/SyncStateService.java
@@ -3,6 +3,7 @@ package com.lanyuanxiaoyao.service.api.service;
 import club.kingon.sql.builder.SqlBuilder;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import com.lanyuanxiaoyao.service.api.entity.HoodieCommitMetadata;
 import com.lanyuanxiaoyao.service.common.Constants;
 import java.time.Instant;
@@ -259,9 +260,10 @@ public class SyncStateService {
                         )
                         .values()
                         .addValue(null, null)
-                        .onDuplicateKeyUpdateColumn(TbAppHudiSyncState.COMPACTION_LATEST_OP_TS_O)
+                        .onDuplicateKeyUpdateSetter(StrUtil.format("{} = GREATEST({}, ?)", TbAppHudiSyncState.COMPACTION_LATEST_OP_TS_O, TbAppHudiSyncState.COMPACTION_LATEST_OP_TS_O))
                         .precompileSql(),
                 syncStateId(flinkJobId, alias),
+                operationDate,
                 operationDate
         );
     }