(Fix) Fix NPE when getting map params (apache#285)

JNSimba · Jan 5, 2024 · f92a0f0 · f92a0f0
1 parent d49eda9
commit f92a0f0
Showing 1 changed file with 1 addition 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
@@ -148,7 +148,7 @@ private static void syncDatabase(
 
     private static Map<String, String> getConfigMap(MultipleParameterTool params, String key) {
         if (!params.has(key)) {
-            return null;
+            return new HashMap<>();
         }
 
         Map<String, String> map = new HashMap<>();
@@ -163,7 +163,6 @@ private static Map<String, String> getConfigMap(MultipleParameterTool params, St
             }
 
             System.err.println("Invalid " + key + " " + param + ".\n");
-            return null;
         }
         return map;
     }