code style

JNSimba · Jan 15, 2024 · 7ce9390 · 7ce9390
1 parent b8d5e1d
commit 7ce9390
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
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
@@ -155,7 +155,12 @@ private static void syncDatabase(
 
     private static Map<String, String> 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
@@ -442,7 +442,7 @@ public DatabaseSync setMultiToOneTarget(String multiToOneTarget) {
     }
 
     public DatabaseSync setTableConfig(Map<String, String> tableConfig) {
-        if(!CollectionUtil.isNullOrEmpty(tableConfig)){
+        if (!CollectionUtil.isNullOrEmpty(tableConfig)) {
             this.tableConfig = tableConfig;
         }
         return this;