Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Fix coding err

Browse source
This commit is contained in:
karuppayya 2016-11-14 22:59:25 +05:30
parent 42dde76080
commit 350d665f20
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java
View file

@ -67,7 +67,7 @@ import org.slf4j.LoggerFactory;
import scala.*;
import scala.Enumeration.Value;
import scala.collection.Iterator;
import scala.collection.JavaConversions;
import scala.collection.JavaConversions;x
import scala.collection.JavaConverters;
import scala.collection.Seq;
import scala.collection.convert.WrapAsJava$;
@ -955,10 +955,10 @@ public class SparkInterpreter extends Interpreter {
public void populateSparkWebUrl(InterpreterContext ctx) {
if (sparkUrl == null) {
String url = getSparkUIUrl();
sparkUrl = getSparkUIUrl();
Map<String, String> infos = new java.util.HashMap<>();
if (url != null) {
infos.put("url", url);
if (sparkUrl != null) {
infos.put("url", sparkUrl);
logger.info("Sending metainfos to Zeppelin server: {}", infos.toString());
if (ctx != null && ctx.getClient() != null) {
ctx.getClient().onMetaInfosReceived(infos);