From 3ce40ef1afbe036c4e3ac355509ce360d2a96b0f Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Tue, 21 May 2024 19:04:57 +0800 Subject: [PATCH] =?UTF-8?q?perf(sync):=20=E8=B0=83=E6=95=B4=E5=BD=92?= =?UTF-8?q?=E6=A1=A3=E4=BF=9D=E7=95=99=E6=97=B6=E9=97=B4=E7=BA=BF=E6=95=B0?= =?UTF-8?q?=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lanyuanxiaoyao/service/sync/utils/ConfigurationUtils.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/utils/ConfigurationUtils.java b/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/utils/ConfigurationUtils.java index 573d193..576cd38 100644 --- a/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/utils/ConfigurationUtils.java +++ b/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/utils/ConfigurationUtils.java @@ -181,9 +181,9 @@ public class ConfigurationUtils { // 时间线保留个数 configuration.setInteger(FlinkOptions.CLEAN_RETAIN_COMMITS, tableMeta.getHudi().getKeepCommitVersion()); // 时间线归档最小保留个数，要比上一个参数大 - configuration.setInteger(FlinkOptions.ARCHIVE_MIN_COMMITS, tableMeta.getHudi().getKeepCommitVersion() + 50); + configuration.setInteger(FlinkOptions.ARCHIVE_MIN_COMMITS, tableMeta.getHudi().getKeepCommitVersion() + 10); // 时间线归档最大保留个数，要比上一个参数大 - configuration.setInteger(FlinkOptions.ARCHIVE_MAX_COMMITS, tableMeta.getHudi().getKeepCommitVersion() + 100); + configuration.setInteger(FlinkOptions.ARCHIVE_MAX_COMMITS, tableMeta.getHudi().getKeepCommitVersion() + 20); // log文件和data文件保留版本数 configuration.setString(FlinkOptions.CLEAN_POLICY, HoodieCleaningPolicy.KEEP_LATEST_FILE_VERSIONS.name()); configuration.setInteger(FlinkOptions.CLEAN_RETAIN_FILE_VERSIONS, tableMeta.getHudi().getKeepFileVersion());