Fix test failure

This commit is contained in:
karuppayya 2016-11-09 22:53:09 +05:30
parent 55c45c9c9e
commit 5cfed2a7b8

View file

@ -960,7 +960,9 @@ public class SparkInterpreter extends Interpreter {
if (url != null) {
infos.put("url", url);
logger.info("Sending metainfos to Zeppelin server: {}", infos.toString());
ctx.getClient().onMetaInfosReceived(infos);
if (ctx != null && ctx.getClient() != null) {
ctx.getClient().onMetaInfosReceived(infos);
}
}
}
}