From 2551eb2ae9cf5b016a384892eeca8b201d131657 Mon Sep 17 00:00:00 2001 From: Andrew Or Date: Tue, 5 Aug 2014 10:44:51 -0700 Subject: [PATCH] Remove spark.worker.watcher.port --- .../scala/org/apache/spark/deploy/worker/DriverWrapper.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala b/core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala index 03da3feec3f0a..05e242e6df702 100644 --- a/core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala +++ b/core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala @@ -30,9 +30,8 @@ object DriverWrapper { args.toList match { case workerUrl :: mainClass :: extraArgs => val conf = new SparkConf() - val watcherPort = conf.getInt("spark.worker.watcher.port", 0) // TODO: document this val (actorSystem, _) = AkkaUtils.createActorSystem("Driver", - Utils.localHostName(), watcherPort, conf, new SecurityManager(conf)) + Utils.localHostName(), 0, conf, new SecurityManager(conf)) actorSystem.actorOf(Props(classOf[WorkerWatcher], workerUrl), name = "workerWatcher") // Delegate to supplied main class