diff --git a/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java b/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java index 7d3caf8a85..f4833f6f86 100644 --- a/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java +++ b/spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java @@ -172,7 +172,9 @@ public class SparkInterpreter extends Interpreter { RemoteEventClientWrapper eventClient = ZeppelinContext.getEventClient(); Map infos = new java.util.HashMap<>(); infos.put("jobUrl", jobUrl); - eventClient.onParaInfosReceived(noteId, paragraphId, infos); + if (eventClient != null) { + eventClient.onParaInfosReceived(noteId, paragraphId, infos); + } } }