Skip to content

Commit 09a0383

Browse files
committed
fix mvn spotless:apply
1 parent 89e8e7b commit 09a0383

1 file changed

Lines changed: 2 additions & 1 deletion

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: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -504,7 +504,8 @@ private static String convertToDebeziumStyle(String tables) {
504504
LOG.debug("After replacing comma with pipe separator: {}", tables);
505505

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

0 commit comments

Comments
 (0)