ThorneANN commented on code in PR #4246:
URL: https://github.com/apache/flink-cdc/pull/4246#discussion_r2958226454
##########
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java:
##########
@@ -243,6 +243,22 @@ public class MySqlSourceOptions {
.withDescription(
"Whether capture the scan the newly added tables
or not, by default is false. This option is only useful when we start the job
from a savepoint/checkpoint.");
+ @Experimental
+ public static final ConfigOption<Boolean>
SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED =
+ ConfigOptions.key("scan.binlog.newly-added-table.enabled")
+ .booleanType()
+ .defaultValue(false)
+ .withDescription(
+ "In binlog reading stage, whether to capture newly
added tables "
+ + "that match the table patterns. When
enabled, new tables will be "
+ + "captured without snapshot, only binlog
events will be emitted. "
+ + "Cannot be enabled together with
'scan.newly-added-table.enabled'. "
+ + "table-name pattern examples: "
+ + "'db\\.*' (all tables in database 'db'),
"
+ + "'db\\.user_\\.*' (tables like
'user_orders', 'user_profiles'), "
+ + "'db\\.order_[0-9]+' (tables like
'order_1', 'order_2'), "
+ + "'db1\\.*,db2\\.user_\\.*' (all tables
in 'db1' and 'user_*' tables in 'db2').");
Review Comment:
U are right and i forget it , fix it soon
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
