From f4c7f9954bc157edfd975f403a31264b112f7520 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Tue, 4 Jun 2024 11:01:21 +0800 Subject: [PATCH] =?UTF-8?q?fix(api):=20=E7=A7=BB=E9=99=A4metadata=E5=8E=9F?= =?UTF-8?q?=E5=A7=8B=E6=95=B0=E6=8D=AE=E5=AD=98=E5=82=A8=EF=BC=8C=E6=8F=90?= =?UTF-8?q?=E9=AB=98=E6=95=B0=E6=8D=AE=E5=BA=93=E6=95=88=E7=8E=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/api/service/SyncStateService.java | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) 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 29b398d..0d4a79a 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 @@ -264,11 +264,10 @@ public class SyncStateService { TbAppHudiCompactionMetrics.COMPACTION_PLAN_INSTANT_O, TbAppHudiCompactionMetrics.CLUSTER_O, TbAppHudiCompactionMetrics.APPLICATION_ID_O, - TbAppHudiCompactionMetrics.UPDATE_TIME_O, - TbAppHudiCompactionMetrics.METADATA_O + TbAppHudiCompactionMetrics.UPDATE_TIME_O ) .values() - .addValue(null, null, null, null, null, null, null, null) + .addValue(null, null, null, null, null, null, null) .precompileSql(), flinkJobId, alias, @@ -276,8 +275,7 @@ public class SyncStateService { Date.from(Instant.ofEpochMilli(DateUtil.parse(instant).getTime())), cluster, applicationId, - now(), - metadataText + now() ); } else { jdbcTemplate.update( @@ -296,11 +294,10 @@ public class SyncStateService { TbAppHudiCompactionMetrics.TOTAL_RECORDS_DELETED_O, TbAppHudiCompactionMetrics.TOTAL_RECORDS_UPDATED_O, TbAppHudiCompactionMetrics.TOTAL_RECORDS_COMPACTED_O, - TbAppHudiCompactionMetrics.UPDATE_TIME_O, - TbAppHudiCompactionMetrics.METADATA_O + TbAppHudiCompactionMetrics.UPDATE_TIME_O ) .values() - .addValue(null, null, null, null, null, null, null, null, null, null, null, null, null, null) + .addValue(null, null, null, null, null, null, null, null, null, null, null, null, null) .precompileSql(), flinkJobId, alias, @@ -314,8 +311,7 @@ public class SyncStateService { metadata.getTotalRecordsDeleted(), metadata.getTotalCompactedRecordsUpdated(), metadata.getTotalLogRecordsCompacted(), - now(), - metadataText + now() ); } }