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() ); } }