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")