diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterServer.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterServer.java index 9b9e063edcc..6c4f87d6728 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterServer.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterServer.java @@ -904,9 +904,12 @@ public String getStatus(String sessionId, String jobId) } for (Interpreter intp : interpreters) { - Job job = intp.getScheduler().getJob(jobId); - if (job != null) { - return job.getStatus().name(); + Scheduler scheduler = intp.getScheduler(); + if (scheduler != null) { + Job job = scheduler.getJob(jobId); + if (job != null) { + return job.getStatus().name(); + } } } }