From 6430bfc0c4dc3e43e07f19a36d5b9b82a58b0935 Mon Sep 17 00:00:00 2001 From: sunxiaojian Date: Wed, 29 Nov 2023 10:37:01 +0800 Subject: [PATCH] fixed --- .../paimon/flink/action/cdc/mysql/MySqlActionITCaseBase.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionITCaseBase.java b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionITCaseBase.java index 4f208cf401f1..be0924179aaa 100644 --- a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionITCaseBase.java +++ b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionITCaseBase.java @@ -89,7 +89,8 @@ protected Map 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; }