Spark系列(十)TaskSchedule工作原理

时间:2022-12-30 16:38:07

工作原理图

Spark系列(十)TaskSchedule工作原理

源码分析:

1、) 25              launchedTask = true 26            } 27          } catch { 28            case e: TaskNotSerializableException => 29              logError(s"Resource offer failed, task set ${taskSet.name} was not serializable") 30              // Do not offer resources for this task, but don't throw an error to allow other 31              // task sets to be submitted. 32              return launchedTask 33          } 34        } 35      } 36      return launchedTask 37    }