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);