[FLINK-FLINK-36115][pipeline-connector][mysql] add scan.incremental.n…

…ewly-added-table.enabled option to Allow to scan newly table DDL during incremental reading stage.
apache · Aug 21, 2024 · 7173b46 · 7173b46
1 parent 5de2c45
commit 7173b46
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/docs/content/docs/connectors/pipeline-connectors/mysql.md b/docs/content/docs/connectors/pipeline-connectors/mysql.md
@@ -289,7 +289,7 @@ pipeline:
       <td>Boolean</td>
       <td>In binlog reading stage, whether to scan the ddl and dml statements of newly added tables or not, by default is false. <br>
           The difference between scan.newly-added-table.enabled and scan.binlog.newly-added-table.enabled options is: <br>
-          scan.newly-added-table.enabled: do re-snapshot & binlog-reading for newly added table when restore; <br>
+          scan.newly-added-table.enabled: do re-snapshot & binlog-reading for newly added table when restored; <br>
           scan.binlog.newly-added-table.enabled: only do binlog-reading for newly added table during binlog reading phase.
       </td>
     </tr>

diff --git a/...ql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java b/...ql/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.");
 }