看看spark的源碼

1. IntelliJ IDEA安裝plugins,加入scala插件和SBT插件

2. 下載spark的源代碼，下載地址 https://github.com/apache/spark，可以使用git下載或者下載zip包

3. 導入項目，開啟 IntelliJ 之后選擇 Import Project，而后選擇 Spark 源代碼，並將其導入為 SBT 項目，在之后的過程中 SBT 過程將會自動進行，下載作為依賴的 jar 包。

4. 源代碼已經准備好了。開干吧

   private def schedule(): Unit = {
       if (state != RecoveryState.ALIVE) {
         return
       }
       // Drivers take strict precedence over executors
       val shuffledAliveWorkers = Random.shuffle(workers.toSeq.filter(_.state == WorkerState.ALIVE))
       val numWorkersAlive = shuffledAliveWorkers.size
       var curPos = 0
       for (driver <- waitingDrivers.toList) { // iterate over a copy of waitingDrivers
         // We assign workers to each waiting driver in a round-robin fashion. For each driver, we
         // start from the last worker that was assigned a driver, and continue onwards until we have
         // explored all alive workers.
         var launched = false
         var numWorkersVisited = 0
         while (numWorkersVisited < numWorkersAlive && !launched) {
           val worker = shuffledAliveWorkers(curPos)
           numWorkersVisited += 1
           if (worker.memoryFree >= driver.desc.mem && worker.coresFree >= driver.desc.cores) {
             launchDriver(worker, driver)
             waitingDrivers -= driver
             launched = true
           }
           curPos = (curPos + 1) % numWorkersAlive
         }
       }
       startExecutorsOnWorkers()
     }