[Hotfix] invalid local properties in ZSession

Kick156 · Dec 17, 2020 · ffd1e50 · ffd1e50
1 parent 5746f6c
commit ffd1e50
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/zeppelin-client/src/main/java/org/apache/zeppelin/client/ZSession.java b/zeppelin-client/src/main/java/org/apache/zeppelin/client/ZSession.java
@@ -362,9 +362,10 @@ public ExecuteResult submit(String subInterpreter,
     }
     if (localProperties != null && !localProperties.isEmpty()) {
       builder.append("(");
-      for (Map.Entry<String, String> entry : localProperties.entrySet()) {
-        builder.append(entry.getKey() + "=\"" + entry.getValue() + "\"");
-      }
+      List<String> propertyString = localProperties.entrySet().stream()
+              .map(entry -> (entry.getKey() + "=\"" + entry.getValue() + "\""))
+              .collect(Collectors.toList());
+      builder.append(StringUtils.join(propertyString, ","));
       builder.append(")");
     }
     builder.append(" " + code);