Skip to content

Commit

Permalink
fixed
Browse files Browse the repository at this point in the history
  • Loading branch information
sunxiaojian committed Nov 29, 2023
1 parent 209d6d2 commit 6430bfc
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,8 @@ protected Map<String, String> getBasicMySqlConfig() {
// see mysql/my.cnf in test resources
config.put("server-time-zone", ZoneId.of("America/New_York").toString());
// Configure after upgrading to version 2.4.1;
// Refer: https://github.com/ververica/flink-cdc-connectors/blob/release-2.4/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java#L272
// Refer:
// https://github.com/ververica/flink-cdc-connectors/blob/release-2.4/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java#L272
config.put("scan.newly-added-table.enabled", "false");
return config;
}
Expand Down

0 comments on commit 6430bfc

Please sign in to comment.