This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 51d1ec9b2c [hotfix] Rename cdc schema change options in
CdcRecordStoreWriteOperator (#4756)
51d1ec9b2c is described below
commit 51d1ec9b2c2e2165c0c3122ab25af83b98fb206e
Author: yuzelin <[email protected]>
AuthorDate: Mon Dec 23 17:06:17 2024 +0800
[hotfix] Rename cdc schema change options in CdcRecordStoreWriteOperator
(#4756)
---
.../paimon/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 8a8233842d..d19e3915f6 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<CdcRecord> {
private static final long serialVersionUID = 1L;
public static final ConfigOption<Duration> 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<Integer> 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<Boolean> SKIP_CORRUPT_RECORD =
ConfigOptions.key("cdc.skip-corrupt-record")
