Changed to store result from jobRun() in Job

jongyoul · jongyoul · commit 69230023cb82 · 2016-12-25T02:35:10.000+09:00
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
@@ -177,7 +177,7 @@ public void run() {
       progressUpdator = new JobProgressPoller(this, progressUpdateIntervalMs);
       progressUpdator.start();
       dateStarted = new Date();
-      jobRun(); // jobRun will store results by itself and job can get it by calling getReturn();
+      setResult(jobRun());
       this.exception = null;
       errorMessage = null;
       dateFinished = new Date();
@@ -233,10 +233,6 @@ public void setJobName(String jobName) {
 
   public abstract Map<String, Object> info();
 
-  /**
-   * jobRun should store the data into results so that job interface gets the result by calling
-   * getReturn();
-   */
   protected abstract Object jobRun() throws Throwable;
 
   protected abstract boolean jobAbort();
