Get progress information in %sql interpreter
Project: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/commit/c6350b62 Tree: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/tree/c6350b62 Diff: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/diff/c6350b62 Branch: refs/heads/master Commit: c6350b625edbecbf07b5c6f089bde1d5f6b9c0aa Parents: 0037741 Author: Lee moon soo <[email protected]> Authored: Sun Mar 15 15:30:29 2015 +0900 Committer: Lee moon soo <[email protected]> Committed: Sun Mar 15 15:30:29 2015 +0900 ---------------------------------------------------------------------- .../main/java/com/nflabs/zeppelin/spark/SparkSqlInterpreter.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/c6350b62/spark/src/main/java/com/nflabs/zeppelin/spark/SparkSqlInterpreter.java ---------------------------------------------------------------------- diff --git a/spark/src/main/java/com/nflabs/zeppelin/spark/SparkSqlInterpreter.java b/spark/src/main/java/com/nflabs/zeppelin/spark/SparkSqlInterpreter.java index f7ed73e..32f5f4e 100644 --- a/spark/src/main/java/com/nflabs/zeppelin/spark/SparkSqlInterpreter.java +++ b/spark/src/main/java/com/nflabs/zeppelin/spark/SparkSqlInterpreter.java @@ -225,6 +225,8 @@ public class SparkSqlInterpreter extends Interpreter { progressInfo = getProgressFromStage_1_1x(sparkListener, job.finalStage()); } else if (sc.version().startsWith("1.2")) { progressInfo = getProgressFromStage_1_1x(sparkListener, job.finalStage()); + } else if (sc.version().startsWith("1.3")) { + progressInfo = getProgressFromStage_1_1x(sparkListener, job.finalStage()); } else { logger.warn("Spark {} getting progress information not supported" + sc.version()); continue;
