Skip to content

Commit bf93c21

Browse files
committed
fix 2
1 parent 723f1a3 commit bf93c21

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfigFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -508,7 +508,7 @@ private static String convertToDebeziumStyle(String tables) {
508508
LOG.debug("After replacing comma with pipe separator: {}", tables);
509509

510510
// Step 2: Replace escaped dot \. with placeholder
511-
// In Flink CDC, \. means any character in regex, in Debezium it should be .
511+
// In Flink CDC, \. means a literal dot in regex, in Debezium it should be . (any character).
512512
String unescapedTables = tables.replace("\\.", "$");
513513
LOG.debug("After unescaping dots as RegEx meta-character: {}", unescapedTables);
514514

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/resources/ddl/binlog_test.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@
2525
-- 4. Non-matching tables are not captured
2626
--
2727
-- IMPORTANT: This SQL file defines the initial schema for reference and documentation.
28-
-- The actual test creates tables dynamically during execution to validate binlog-only capture.
29-
-- The initial_table is crea1ted in @BeforeEach to ensure binlog is active before CDC source starts.
28+
-- The actual test created tables dynamically during execution to validate binlog-only capture.
29+
-- The initial_table is created in @BeforeEach to ensure binlog is active before CDC source starts.
3030

3131
-- Initial table to activate binlog
3232
-- This table is actually created in test code, but defined here for reference

0 commit comments

Comments
 (0)