@@ -44,7 +44,7 @@ import org.apache.spark.util.{ActorLogReceive, AkkaUtils, SignalLogger, Utils}
44
44
*/
45
45
private [worker] class Worker (
46
46
host : String ,
47
- port : String ,
47
+ port : Int ,
48
48
webUiPort : String ,
49
49
cores : Int ,
50
50
memory : Int ,
@@ -196,8 +196,7 @@ private[worker] class Worker(
196
196
for (masterAkkaUrl <- masterAkkaUrls) {
197
197
logInfo(" Connecting to master " + masterAkkaUrl + " ..." )
198
198
val actor = context.actorSelection(masterAkkaUrl)
199
- actor ! RegisterWorker (workerId, host, port.toInt, cores, memory,
200
- webUi.boundPort, publicAddress)
199
+ actor ! RegisterWorker (workerId, host, port, cores, memory, webUi.boundPort, publicAddress)
201
200
}
202
201
}
203
202
@@ -236,7 +235,7 @@ private[worker] class Worker(
236
235
*/
237
236
if (master != null ) {
238
237
master ! RegisterWorker (
239
- workerId, host, port.toInt , cores, memory, webUi.boundPort, publicAddress)
238
+ workerId, host, port, cores, memory, webUi.boundPort, publicAddress)
240
239
} else {
241
240
// We are retrying the initial registration
242
241
tryRegisterAllMasters()
@@ -482,7 +481,7 @@ private[worker] class Worker(
482
481
masterDisconnected()
483
482
484
483
case RequestWorkerState =>
485
- sender ! WorkerStateResponse (host, port.toInt , workerId, executors.values.toList,
484
+ sender ! WorkerStateResponse (host, port, workerId, executors.values.toList,
486
485
finishedExecutors.values.toList, drivers.values.toList,
487
486
finishedDrivers.values.toList, activeMasterUrl, cores, memory,
488
487
coresUsed, memoryUsed, activeMasterWebUiUrl)
0 commit comments