From 51d1ec9b2c2e2165c0c3122ab25af83b98fb206e Mon Sep 17 00:00:00 2001 From: yuzelin <33053040+yuzelin@users.noreply.github.com> Date: Mon, 23 Dec 2024 17:06:17 +0800 Subject: [PATCH] [hotfix] Rename cdc schema change options in CdcRecordStoreWriteOperator (#4756) --- .../flink/sink/cdc/CdcRecordStoreWriteOperator.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreWriteOperator.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreWriteOperator.java index 8a8233842df7..d19e3915f621 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreWriteOperator.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreWriteOperator.java @@ -48,15 +48,18 @@ public class CdcRecordStoreWriteOperator extends TableWriteOperator { private static final long serialVersionUID = 1L; public static final ConfigOption RETRY_SLEEP_TIME = - ConfigOptions.key("cdc.retry-sleep-time") + ConfigOptions.key("cdc.schema-change-retry-interval") .durationType() - .defaultValue(Duration.ofMillis(500)); + .defaultValue(Duration.ofMillis(500)) + .withFallbackKeys("cdc.retry-sleep-time") + .withDescription("The interval of retrying the schema change."); public static final ConfigOption MAX_RETRY_NUM_TIMES = - ConfigOptions.key("cdc.max-retry-num-times") + ConfigOptions.key("cdc.schema-change-retry-max-num") .intType() .defaultValue(100) - .withDescription("Max retry count for updating table before failing loudly"); + .withDescription( + "Max retry count for retrying the schema change before failing loudly"); public static final ConfigOption SKIP_CORRUPT_RECORD = ConfigOptions.key("cdc.skip-corrupt-record")