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 4d1fa90 [hotfix] Make more meaningful error message for job run exception 4d1fa90 is described below commit 4d1fa9001257656a972944930e0a2bdb6184523e Author: Jeff Zhang <zjf...@apache.org> AuthorDate: Sat Jan 4 23:28:12 2020 +0800 [hotfix] Make more meaningful error message for job run exception --- .../apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java | 2 +- .../src/main/java/org/apache/zeppelin/notebook/Paragraph.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java index c3428bd..15894fe 100644 --- a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java +++ b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/launcher/SparkInterpreterLauncher.java @@ -124,7 +124,7 @@ public class SparkInterpreterLauncher extends StandardInterpreterLauncher { sparkProperties.put("spark.jars", StringUtils.join(additionalJars, ",")); } } catch (Exception e) { - throw new IOException("Cannot make a list of additional jars from localRepo: {}", e); + throw new IOException("Fail to set additional jars for spark interpreter", e); } } diff --git a/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Paragraph.java b/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Paragraph.java index a21fd33..09838f4 100644 --- a/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Paragraph.java +++ b/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Paragraph.java @@ -558,7 +558,7 @@ public class Paragraph extends JobWithProgressPoller<InterpreterResult> implemen InterpreterContext.remove(); } } catch (Exception e) { - return new InterpreterResult(Code.ERROR, e.getMessage()); + return new InterpreterResult(Code.ERROR, ExceptionUtils.getStackTrace(e)); } }