From 30b90342410a196d99d25113fbc1e37ce2a8200f Mon Sep 17 00:00:00 2001
From: Patrick Wendell <pwendell@gmail.com>
Date: Mon, 1 Jul 2013 13:48:01 -0700
Subject: [PATCH] Fixing bug where logs aren't shown
---
core/src/main/scala/spark/deploy/worker/Worker.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/core/src/main/scala/spark/deploy/worker/Worker.scala b/core/src/main/scala/spark/deploy/worker/Worker.scala
index b6a26245fc..6ae1cef940 100644
--- a/core/src/main/scala/spark/deploy/worker/Worker.scala
+++ b/core/src/main/scala/spark/deploy/worker/Worker.scala
@@ -45,7 +45,7 @@ private[spark] class Worker(
val envVar = System.getenv("SPARK_PUBLIC_DNS")
if (envVar != null) envVar else host
}
- val webUi = new WorkerWebUI(self, workDir, Some(webUiPort))
+ var webUi: WorkerWebUI = null
var coresUsed = 0
var memoryUsed = 0
@@ -77,6 +77,7 @@ private[spark] class Worker(
sparkHome = new File(Option(System.getenv("SPARK_HOME")).getOrElse("."))
logInfo("Spark home: " + sparkHome)
createWorkDir()
+ webUi = new WorkerWebUI(self, workDir, Some(webUiPort))
webUi.start()
connectToMaster()
}
--
GitLab