remove unnecessary change

apache · May 9, 2019 · 94a866d · 94a866d
1 parent 17920b3
commit 94a866d
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
@@ -486,7 +486,6 @@ private[deploy] class Worker(
 
     case MasterChanged(masterRef, masterWebUiUrl) =>
       logInfo("Master has changed, new master is at " + masterRef.address.toSparkURL)
-      registered = true
       changeMaster(masterRef, masterWebUiUrl, masterRef.address)
 
       val execs = executors.values.
@@ -496,7 +495,7 @@ private[deploy] class Worker(
     case ReconnectWorker(masterUrl) =>
       if (masterUrl != activeMasterUrl) {
         logWarning(s"New Master is at $activeMasterUrl, " +
-          s"ignore old Master ($masterUrl)'s request to reconnect")
+          s"ignore old Master ($masterUrl)'s request to reconnect.")
       } else {
         logInfo(s"Master with url $masterUrl requested this worker to reconnect.")
         registerWithMaster()