From b1c80e79894e7ef08ade9680f0f532ae591c450c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Nicol=C3=B2=20Boschi?= Date: Mon, 18 Oct 2021 10:11:30 +0200 Subject: [PATCH] [function] fix update user config (#10731) Fixes #10720 fix update user config (cherry picked from commit 791c0ac5b4ac23f31c37adf7d26eb87998ccd0ef) --- .../main/java/org/apache/pulsar/admin/cli/CmdFunctions.java | 6 +++--- 1 file changed, 3 insertions(+), 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 index 8df1fe40f6da3..26aec7ccab78a 100644 --- 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>() {}.getType(); Map 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);