From 022119304a761259f4520fc2899cc640570a6074 Mon Sep 17 00:00:00 2001 From: Jeff Zhang Date: Tue, 7 Mar 2017 15:02:37 +0800 Subject: [PATCH 1/2] ZEPPELIN-2224. Throw more meaningful exception when kerberos is enabled in livy interpreter --- .../java/org/apache/zeppelin/livy/BaseLivyInterprereter.java | 3 +++ 1 file changed, 3 insertions(+) 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 d29d20c3ecc..fd3d6e3c2c7 100644 --- a/livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java +++ b/livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java @@ -25,6 +25,7 @@ import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.conn.ssl.SSLContexts; import org.apache.http.impl.client.HttpClients; +import org.apache.commons.lang.exception.ExceptionUtils; import org.apache.zeppelin.interpreter.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -484,6 +485,8 @@ private String callRestAPI(String targetURL, String method, String jsonData) if (cause.getResponseBodyAsString().matches(SESSION_NOT_FOUND_PATTERN)) { throw new SessionNotFoundException(cause.getResponseBodyAsString()); } + throw new LivyException(cause.getResponseBodyAsString() + "\n" + + ExceptionUtils.getFullStackTrace(ExceptionUtils.getRootCause(e))); } throw new LivyException(e); } From 67feb4cea2621ca9bf8beb6032ea5bc9a955feae Mon Sep 17 00:00:00 2001 From: Jeff Zhang Date: Tue, 7 Mar 2017 15:38:29 +0800 Subject: [PATCH 2/2] code cleanup --- .../java/org/apache/zeppelin/livy/BaseLivyInterprereter.java | 2 -- 1 file changed, 2 deletions(-) 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 fd3d6e3c2c7..9c1301f0ceb 100644 --- a/livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java +++ b/livy/src/main/java/org/apache/zeppelin/livy/BaseLivyInterprereter.java @@ -368,13 +368,11 @@ private InterpreterResult getResultFromStatementInfo(StatementInfo stmtInfo, } if (displayAppInfo) { - //TODO(zjffdu), use multiple InterpreterResult to display appInfo InterpreterResult interpreterResult = new InterpreterResult(InterpreterResult.Code.SUCCESS); interpreterResult.add(InterpreterResult.Type.TEXT, result); String appInfoHtml = "
Spark Application Id: " + sessionInfo.appId + "
" + "Spark WebUI: " + sessionInfo.webUIAddress + ""; - LOGGER.info("appInfoHtml:" + appInfoHtml); interpreterResult.add(InterpreterResult.Type.HTML, appInfoHtml); return interpreterResult; } else {