Update RemoteSchedulerTest

Leemoonsoo · Leemoonsoo · commit 6405abe24fb2 · 2015-03-28T19:35:09.000+09:00
diff --git a/zeppelin-interpreter/src/test/java/com/nflabs/zeppelin/scheduler/RemoteSchedulerTest.java b/zeppelin-interpreter/src/test/java/com/nflabs/zeppelin/scheduler/RemoteSchedulerTest.java
@@ -53,7 +53,7 @@ public void test() throws Exception {
         intpA.getInterpreterProcess(),
         10);
 
-    scheduler.submit(new Job("jobName", null) {
+    Job job = new Job("jobId", "jobName", null, 200) {
 
       @Override
       public int progress() {
@@ -68,7 +68,7 @@ public Map<String, Object> info() {
       @Override
       protected Object jobRun() throws Throwable {
         intpA.interpret("500", new InterpreterContext(
-            "id",
+            "jobId",
             "title",
             "text",
             new HashMap<String, Object>(),
@@ -80,8 +80,12 @@ protected Object jobRun() throws Throwable {
       protected boolean jobAbort() {
         return false;
       }
+    };
+    scheduler.submit(job);
 
-    });
+    while (job.isTerminated() == false) {
+      Thread.sleep(200);
+    }
 
     intpA.close();
     schedulerSvc.removeScheduler("test");
