commit f92a0f0d6a25afab7d2594ae4009fdd5ac916aae
author Fangbin Sun <sunfangbin@gmail.com> Fri Jan 05 14:30:55 2024 +0800
committer GitHub <noreply@github.com> Fri Jan 05 14:30:55 2024 +0800
tree 955fcb58924408e735f3bfb6d9d4323c267650ee
parent d49eda9c0f766b9ee2561da850a3a137c5ad7c5a

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

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java

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 18adde2..2841c25 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
@@ -148,7 +148,7 @@
 
     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 @@
             }
 
             System.err.println("Invalid " + key + " " + param + ".\n");
-            return null;
         }
         return map;
     }