add log info

Author: liyezhang556520

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

@@ -366,8 +366,11 @@ private[spark] class Master(
               " Asking it to re-register.")
             sender ! ReconnectWorker(masterUrl)
           } else {
+            // Get unknown worker's heart beat, tell the worker disconnected. And worker need to
+            // register to this master first.
             logWarning(s"Got heartbeat from unregistered worker $workerId." +
-              " This worker was never registered, so ignoring the heartbeat.")
+              " This worker was never registered, tell the worker connection is disconnected." +
+              " Need to re-register if want to connect.")
             sender ! MasterDisconnected(masterUrl)
           }
       }

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

@@ -466,7 +466,12 @@ private[spark] class Worker(
       maybeCleanupApplication(id)
 
     case MasterDisconnected(masterUrl) =>
-      masterDisconnected()
+      if (masterUrl != activeMasterUrl) {
+        logWarning(s"Get message from Invalid Master ($masterUrl)." +
+          s"Valid Master is : $activeMasterUrl, so ignore the message.")
+      } else {
+        masterDisconnected()
+      }
   }
 
   private def masterDisconnected() {