From e2cd4db0211bc26d7bf8d3ea40f75ef13217e9e7 Mon Sep 17 00:00:00 2001 From: karuppayya Date: Tue, 22 Nov 2016 10:42:37 +0530 Subject: [PATCH] Fix NPE in tests Signed-off-by: karuppayya --- .../main/java/org/apache/zeppelin/spark/SparkInterpreter.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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); + } } }