From 7173b46a203debeb0541777852eadf00d6228fe6 Mon Sep 17 00:00:00 2001 From: kunni Date: Wed, 21 Aug 2024 20:23:46 +0800 Subject: [PATCH] [FLINK-FLINK-36115][pipeline-connector][mysql] add scan.incremental.newly-added-table.enabled option to Allow to scan newly table DDL during incremental reading stage. --- docs/content/docs/connectors/pipeline-connectors/mysql.md | 2 +- .../cdc/connectors/mysql/source/MySqlDataSourceOptions.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/content/docs/connectors/pipeline-connectors/mysql.md b/docs/content/docs/connectors/pipeline-connectors/mysql.md index 819da0d090..36c4cc7708 100644 --- a/docs/content/docs/connectors/pipeline-connectors/mysql.md +++ b/docs/content/docs/connectors/pipeline-connectors/mysql.md @@ -289,7 +289,7 @@ pipeline: Boolean In binlog reading stage, whether to scan the ddl and dml statements of newly added tables or not, by default is false.
The difference between scan.newly-added-table.enabled and scan.binlog.newly-added-table.enabled options is:
- scan.newly-added-table.enabled: do re-snapshot & binlog-reading for newly added table when restore;
+ scan.newly-added-table.enabled: do re-snapshot & binlog-reading for newly added table when restored;
scan.binlog.newly-added-table.enabled: only do binlog-reading for newly added table during binlog reading phase. diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java index bc9d8b7bfd..580d370b5a 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java @@ -270,6 +270,6 @@ public class MySqlDataSourceOptions { .withDescription( "In binlog reading stage, whether to scan the ddl and dml statements of newly added tables or not, by default is false. \n" + "The difference between scan.newly-added-table.enabled and scan.binlog.newly-added-table.enabled options is: \n" - + "scan.newly-added-table.enabled: do re-snapshot & binlog-reading for newly added table when restore; \n" + + "scan.newly-added-table.enabled: do re-snapshot & binlog-reading for newly added table when restored; \n" + "scan.binlog.newly-added-table.enabled: only do binlog-reading for newly added table during binlog reading phase."); }