diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/Job.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/Job.java index 4c8c70a4af..7d90db4c19 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/Job.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/Job.java @@ -58,15 +58,15 @@ public abstract class Job { FINISHED, ERROR, ABORT; - boolean isReady() { + public boolean isReady() { return this == READY; } - boolean isRunning() { + public boolean isRunning() { return this == RUNNING; } - boolean isPending() { + public boolean isPending() { return this == PENDING; } } diff --git a/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Note.java b/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Note.java index 93dcec582a..5aa27c4252 100644 --- a/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Note.java +++ b/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Note.java @@ -303,6 +303,9 @@ public class Note implements Serializable, JobListener { info.put("status", p.getStatus().toString()); info.put("started", p.getDateStarted().toString()); info.put("finished", p.getDateFinished().toString()); + if (p.getStatus().isRunning()) { + info.put("progress", String.valueOf(p.progress())); + } paragraphsInfo.add(info); } }