From 2ef8dbd00a231eeb84c4de96762357df74c614c6 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Mon, 29 Apr 2024 16:59:13 +0800 Subject: [PATCH] =?UTF-8?q?feat(api):=20latest=5Fop=5Fts=E6=8C=89=E8=BE=83?= =?UTF-8?q?=E5=A4=A7=E5=80=BC=E6=9B=B4=E6=96=B0=E5=88=B0=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lanyuanxiaoyao/service/api/service/SyncStateService.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 ); }