You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by zj...@apache.org on 2020/12/17 03:06:18 UTC

[zeppelin] branch master updated: [Hotfix] invalid local properties in ZSession

This is an automated email from the ASF dual-hosted git repository.

zjffdu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git


The following commit(s) were added to refs/heads/master by this push:
     new ffd1e50  [Hotfix] invalid local properties in ZSession
ffd1e50 is described below

commit ffd1e502c404a0970042d0023f3c2e1a983c86f1
Author: Jeff Zhang <zj...@apache.org>
AuthorDate: Thu Dec 17 11:05:38 2020 +0800

    [Hotfix] invalid local properties in ZSession
---
 .../src/main/java/org/apache/zeppelin/client/ZSession.java         | 7 ++++---
 1 file changed, 4 insertions(+), 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
index f411ed6..9dbcfda 100644
--- 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 class ZSession {
     }
     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);