[function] fix update user config (apache#10731)

Fixes apache#10720 fix update user config (cherry picked from commit 791c0ac)
datastax · Oct 18, 2021 · b1c80e7 · b1c80e7
1 parent 1ffa32c
commit b1c80e7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
@@ -448,11 +448,11 @@ void processArguments() throws Exception {
             if (null != userConfigString) {
                 Type type = new TypeToken<Map<String, String>>() {}.getType();
                 Map<String, Object> userConfigMap = new Gson().fromJson(userConfigString, type);
+                if (userConfigMap == null) {
+                    userConfigMap = new HashMap<>();
+                }
                 functionConfig.setUserConfig(userConfigMap);
             }
-            if (functionConfig.getUserConfig() == null) {
-                functionConfig.setUserConfig(new HashMap<>());
-            }
 
             if (parallelism != null) {
                 functionConfig.setParallelism(parallelism);