From 7ce9390024ed61f12245ba45afa986b8e41fc184 Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Mon, 15 Jan 2024 18:32:06 +0800 Subject: [PATCH] code style --- .../java/org/apache/doris/flink/tools/cdc/CdcTools.java | 7 ++++++- .../org/apache/doris/flink/tools/cdc/DatabaseSync.java | 2 +- 2 files changed, 7 insertions(+), 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 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;