From c47d2ddf72dde17faf0eb3e030ee30b1543d10cd Mon Sep 17 00:00:00 2001 From: kunni Date: Thu, 4 Jul 2024 19:49:40 +0800 Subject: [PATCH 1/2] [FLINK-35758][doc] add scan.startup.timestamp-millis to mysql connector options. --- .../docs/connectors/flink-sources/mysql-cdc.md | 7 +++++++ .../docs/connectors/pipeline-connectors/mysql.md | 10 ++++++++-- .../content/docs/connectors/flink-sources/mysql-cdc.md | 7 +++++++ .../docs/connectors/pipeline-connectors/mysql.md | 10 ++++++++-- 4 files changed, 30 insertions(+), 4 deletions(-) diff --git a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md index 4e34d4da583..637e3a30b08 100644 --- a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md +++ b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md @@ -285,6 +285,13 @@ Flink SQL> SELECT * FROM orders; String 在 "specific-offset" 启动模式下，启动位点的 GTID 集合。 + + scan.startup.timestamp-millis + optional + (none) + Long + 在 "timestamp" 启动模式下，启动位点的毫秒时间戳 + scan.startup.specific-offset.skip-events optional diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md index fa6056cd986..2b202e1cb49 100644 --- a/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md +++ b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md @@ -172,8 +172,7 @@ pipeline: initial String MySQL CDC 消费者可选的启动模式， - 合法的模式为 "initial"，"earliest-offset"，"latest-offset"，"specific-offset" 和 "timestamp"。 - 请查阅 启动模式 章节了解更多详细信息。 + 合法的模式为 "initial"，"earliest-offset"，"latest-offset"，"specific-offset" 和 "timestamp"。 scan.startup.specific-offset.file @@ -196,6 +195,13 @@ pipeline: String 在 "specific-offset" 启动模式下，启动位点的 GTID 集合。 + + scan.startup.timestamp-millis + optional + (none) + Long + 在 "timestamp" 启动模式下，启动位点的毫秒时间戳 + scan.startup.specific-offset.skip-events optional diff --git a/docs/content/docs/connectors/flink-sources/mysql-cdc.md b/docs/content/docs/connectors/flink-sources/mysql-cdc.md index 5c2cbe546a9..af57a100ab5 100644 --- a/docs/content/docs/connectors/flink-sources/mysql-cdc.md +++ b/docs/content/docs/connectors/flink-sources/mysql-cdc.md @@ -283,6 +283,13 @@ Connector Options String Optional GTID set used in case of "specific-offset" startup mode + + scan.startup.timestamp-millis + optional + (none) + Long + Optional millisecond timestamp used in case of "timestamp" startup mode + scan.startup.specific-offset.skip-events optional diff --git a/docs/content/docs/connectors/pipeline-connectors/mysql.md b/docs/content/docs/connectors/pipeline-connectors/mysql.md index 9eef3d7a4a5..b88b3164a63 100644 --- a/docs/content/docs/connectors/pipeline-connectors/mysql.md +++ b/docs/content/docs/connectors/pipeline-connectors/mysql.md @@ -175,8 +175,7 @@ pipeline: optional initial String - Optional startup mode for MySQL CDC consumer, valid enumerations are "initial", "earliest-offset", "latest-offset", "specific-offset" and "timestamp". - Please see Startup Reading Position section for more detailed information. + Optional startup mode for MySQL CDC consumer, valid enumerations are "initial", "earliest-offset", "latest-offset", "specific-offset" and "timestamp". scan.startup.specific-offset.file @@ -199,6 +198,13 @@ pipeline: String Optional GTID set used in case of "specific-offset" startup mode + + scan.startup.timestamp-millis + optional + (none) + Long + Optional millisecond timestamp used in case of "timestamp" startup mode + scan.startup.specific-offset.skip-events optional From 76ea20af38e220bbf7359440598115e1f717dca1 Mon Sep 17 00:00:00 2001 From: kunni Date: Thu, 4 Jul 2024 19:52:04 +0800 Subject: [PATCH 2/2] [FLINK-35758][doc] add scan.startup.timestamp-millis to mysql connector options. --- docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md | 2 +- docs/content.zh/docs/connectors/pipeline-connectors/mysql.md | 2 +- docs/content/docs/connectors/flink-sources/mysql-cdc.md | 2 +- docs/content/docs/connectors/pipeline-connectors/mysql.md | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md index 637e3a30b08..7f400af238f 100644 --- a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md +++ b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md @@ -290,7 +290,7 @@ Flink SQL> SELECT * FROM orders; optional (none) Long - 在 "timestamp" 启动模式下，启动位点的毫秒时间戳 + 在 "timestamp" 启动模式下，启动位点的毫秒时间戳。 scan.startup.specific-offset.skip-events diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md index 2b202e1cb49..e7e53f396b8 100644 --- a/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md +++ b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md @@ -200,7 +200,7 @@ pipeline: optional (none) Long - 在 "timestamp" 启动模式下，启动位点的毫秒时间戳 + 在 "timestamp" 启动模式下，启动位点的毫秒时间戳。 scan.startup.specific-offset.skip-events diff --git a/docs/content/docs/connectors/flink-sources/mysql-cdc.md b/docs/content/docs/connectors/flink-sources/mysql-cdc.md index af57a100ab5..1a9f92fb7a1 100644 --- a/docs/content/docs/connectors/flink-sources/mysql-cdc.md +++ b/docs/content/docs/connectors/flink-sources/mysql-cdc.md @@ -288,7 +288,7 @@ Connector Options optional (none) Long - Optional millisecond timestamp used in case of "timestamp" startup mode + Optional millisecond timestamp used in case of "timestamp" startup mode. scan.startup.specific-offset.skip-events diff --git a/docs/content/docs/connectors/pipeline-connectors/mysql.md b/docs/content/docs/connectors/pipeline-connectors/mysql.md index b88b3164a63..834b51070f0 100644 --- a/docs/content/docs/connectors/pipeline-connectors/mysql.md +++ b/docs/content/docs/connectors/pipeline-connectors/mysql.md @@ -203,7 +203,7 @@ pipeline: optional (none) Long - Optional millisecond timestamp used in case of "timestamp" startup mode + Optional millisecond timestamp used in case of "timestamp" startup mode. scan.startup.specific-offset.skip-events