This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new f92a0f0 (Fix) Fix NPE when getting map params (#285)
f92a0f0 is described below
commit f92a0f0d6a25afab7d2594ae4009fdd5ac916aae
Author: Fangbin Sun <[email protected]>
AuthorDate: Fri Jan 5 14:30:55 2024 +0800
(Fix) Fix NPE when getting map params (#285)
---
.../src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java | 3 +--
1 file changed, 1 insertion(+), 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 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 @@ public class CdcTools {
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 @@ public class CdcTools {
}
System.err.println("Invalid " + key + " " + param + ".\n");
- return null;
}
return map;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
