Skip to content

Commit 3b37070

Browse files
committed
Fix NPE in Master WebUI after recoverying Master
1 parent f84e325 commit 3b37070

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

core/src/main/scala/org/apache/spark/deploy/master/ApplicationInfo.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ private[spark] class ApplicationInfo(
6666
nextExecutorId = 0
6767
removedExecutors = new ArrayBuffer[ExecutorDesc]
6868
executorLimit = Integer.MAX_VALUE
69+
appUIUrlAtHistoryServer = None
6970
}
7071

7172
private def newExecutorId(useID: Option[Int] = None): Int = {

core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -690,7 +690,7 @@ private[deploy] object Worker extends Logging {
690690
val conf = new SparkConf
691691
val args = new WorkerArguments(argStrings, conf)
692692
val rpcEnv = startRpcEnvAndEndpoint(args.host, args.port, args.webUiPort, args.cores,
693-
args.memory, args.masters, args.workDir)
693+
args.memory, args.masters, args.workDir, conf = conf)
694694
rpcEnv.awaitTermination()
695695
}
696696

0 commit comments

Comments
 (0)