Repository: zeppelin Updated Branches: refs/heads/master 293993c60 -> 4178089a0
ZEPPELIN-1311. Typo in ZEPPELIN-1197 ### What is this PR for? My bad, it should be `Exception` rather than `Execution`  ### What type of PR is it? [Bug Fix] ### Todos * [ ] - Task ### What is the Jira issue? * https://issues.apache.org/jira/browse/ZEPPELIN-1311 ### How should this be tested? Tested manually. ### Screenshots (if appropriate) Here's the new log after this fix.  ### Questions: * Does the licenses files need update? No * Is there breaking changes for older versions? No * Does this needs documentation? No Author: Jeff Zhang <[email protected]> Closes #1307 from zjffdu/ZEPPELIN-1311 and squashes the following commits: e289c58 [Jeff Zhang] ZEPPELIN-1311. Typo in ZEPPELIN-1197 Project: http://git-wip-us.apache.org/repos/asf/zeppelin/repo Commit: http://git-wip-us.apache.org/repos/asf/zeppelin/commit/4178089a Tree: http://git-wip-us.apache.org/repos/asf/zeppelin/tree/4178089a Diff: http://git-wip-us.apache.org/repos/asf/zeppelin/diff/4178089a Branch: refs/heads/master Commit: 4178089a0af2fba0ff032a89540becefd5ec4f41 Parents: 293993c Author: Jeff Zhang <[email protected]> Authored: Tue Aug 9 17:19:47 2016 +0800 Committer: Mina Lee <[email protected]> Committed: Tue Aug 9 18:56:46 2016 +0900 ---------------------------------------------------------------------- spark/src/main/resources/python/zeppelin_pyspark.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/zeppelin/blob/4178089a/spark/src/main/resources/python/zeppelin_pyspark.py ---------------------------------------------------------------------- diff --git a/spark/src/main/resources/python/zeppelin_pyspark.py b/spark/src/main/resources/python/zeppelin_pyspark.py index 2e95c85..9a40556 100644 --- a/spark/src/main/resources/python/zeppelin_pyspark.py +++ b/spark/src/main/resources/python/zeppelin_pyspark.py @@ -28,6 +28,7 @@ from pyspark.accumulators import Accumulator, AccumulatorParam from pyspark.broadcast import Broadcast from pyspark.serializers import MarshalSerializer, PickleSerializer import ast +import traceback # for back compatibility from pyspark.sql import SQLContext, HiveContext, Row @@ -262,7 +263,7 @@ while True : code = compile(mod, '<stdin>', 'single') exec(code) except: - raise Execution(sys.exc_info()) + raise Exception(traceback.format_exc()) intp.setStatementsFinished("", False) except Py4JJavaError:
