Skip to content

Commit

Permalink
[hotfix] Apply spotless to fix checkstyle violation in flink-cdc modu…
Browse files Browse the repository at this point in the history
…le (#3092)
  • Loading branch information
yuzelin authored Mar 26, 2024
1 parent ceb0a9c commit 3468319
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -100,10 +100,10 @@ protected Schema retrieveSchema() throws Exception {

@Override
protected MySqlSource<String> buildSource() {
String tableList =
cdcSourceConfig.get(MySqlSourceOptions.DATABASE_NAME)
+ "\\."
+ cdcSourceConfig.get(MySqlSourceOptions.TABLE_NAME);
String tableList =
cdcSourceConfig.get(MySqlSourceOptions.DATABASE_NAME)
+ "\\."
+ cdcSourceConfig.get(MySqlSourceOptions.TABLE_NAME);
return MySqlActionUtils.buildMySqlSource(cdcSourceConfig, tableList, typeMapping);
}

Expand Down

0 comments on commit 3468319

Please sign in to comment.