From a6f7faf764b498b12c855a0f9a5c8f784a406bc9 Mon Sep 17 00:00:00 2001 From: Jeff Zhang Date: Tue, 24 Jan 2017 16:56:22 +0800 Subject: [PATCH] ZEPPELIN-2006. Livy interpreter doesn't work in anonymous mode --- .../java/org/apache/zeppelin/livy/BaseLivyInterprereter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java b/livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java index 6b72906d314..1b209c5ce31 100644 --- a/livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java +++ b/livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java @@ -206,7 +206,8 @@ private SessionInfo createSession(String user, String kind) conf.put(entry.getKey().toString().substring(5), entry.getValue().toString()); } - CreateSessionRequest request = new CreateSessionRequest(kind, user, conf); + CreateSessionRequest request = new CreateSessionRequest(kind, + user.equals("anonymous") ? null : user, conf); SessionInfo sessionInfo = SessionInfo.fromJson( callRestAPI("/sessions", "POST", request.toJson())); long start = System.currentTimeMillis();