diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java index 77d9d847e..c76506aeb 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java @@ -155,7 +155,12 @@ private static void syncDatabase( private static Map getConfigMap(MultipleParameterTool params, String key) { if (!params.has(key)) { - System.out.println("Can not find key [" + key + "] from args: " + params.toMap().toString() + ".\n"); + System.out.println( + "Can not find key [" + + key + + "] from args: " + + params.toMap().toString() + + ".\n"); return null; } diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java index cd31282e6..b6bb5e5e3 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java @@ -442,7 +442,7 @@ public DatabaseSync setMultiToOneTarget(String multiToOneTarget) { } public DatabaseSync setTableConfig(Map tableConfig) { - if(!CollectionUtil.isNullOrEmpty(tableConfig)){ + if (!CollectionUtil.isNullOrEmpty(tableConfig)) { this.tableConfig = tableConfig; } return this;