keep schedule() calling in the main thread

Author: CodingCat

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

@@ -175,6 +175,8 @@ private[spark] class Master(
       }
     }
 
+    case TriggerSchedule => schedule()
+
     case RevokedLeadership => {
       logError("Leadership has been revoked -- master shutting down.")
       System.exit(0)
@@ -448,7 +450,7 @@ private[spark] class Master(
     }
 
     state = RecoveryState.ALIVE
-    schedule()
+    self ! TriggerSchedule
     logInfo("Recovery complete - resuming operations!")
   }
 

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

@@ -39,4 +39,6 @@ private[master] object MasterMessages {
   case object RequestWebUIPort
 
   case class WebUIPortResponse(webUIBoundPort: Int)
+
+  case object TriggerSchedule
 }