spark的task调度器(FAIR公平调度算法)
Posted hanhaotian
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了spark的task调度器(FAIR公平调度算法)相关的知识,希望对你有一定的参考价值。
private[spark] class FairSchedulingAlgorithm extends SchedulingAlgorithm { override def comparator(s1: Schedulable, s2: Schedulable): Boolean = { val minShare1 = s1.minShare val minShare2 = s2.minShare 默认为0,除非通过fair的配置文件进行了配置指定 val runningTasks1 = s1.runningTasks val runningTasks2 = s2.runningTasks 如果是TaskSetManager时,就是taskSet中运行的task的个数, 如果是Pool实例是表示是所有使用这个poolName的所有的TaskSetManager正在运行的task的个数. val s1Needy = runningTasks1 < minShare1 val s2Needy = runningTasks2 < minShare2 只有在minShare在fair的配置文件中显示配置,同时大于正在运行的task的个数时,才会为true val minShareRatio1 = runningTasks1.toDouble / math.max(minShare1, 1.0).toDouble val minShareRatio2 = runningTasks2.toDouble / math.max(minShare2, 1.0).toDouble 运行的task的个数针对于minShare的比重 val taskToWeightRatio1 = runningTasks1.toDouble / s1.weight.toDouble val taskToWeightRatio2 = runningTasks2.toDouble / s2.weight.toDouble 得到正在运行的task个数针对于pool的weight的比重 var compare: Int = 0 这里首先根据正在运行的task的个数是否已经达到调度队列中最小的分片的个数来进行排序, 如果s1中运行运行的个数小于s1的pool的配置的minShare,返回true,表示s1排序在前面. 如果s2中运行的task的个数小于s2的pool中配置的minShare(最小分片数)的值,表示s1小于s2,这时s2排序应该靠前. if (s1Needy && !s2Needy) { return true } else if (!s1Needy && s2Needy) { return false } else if (s1Needy && s2Needy) { 这种情况表示s1与s2两个队列中,正在运行的task的个数都已经大于(不小于)了两个子调度器中配置的minShare的个数时,根据两个子调度器队列中正在运行的task的个数对应此调度器中最小分片的值所占的比重最小的一个排序更靠前 compare = minShareRatio1.compareTo(minShareRatio2) } else { 这种情况表示s1与s2两个子调度器的队列中,正在运行的task的个数都还没有达到配置的最小分片的个数的情况,比较两个队列中正在运行的task的个数对应调度器队列的weigth的占比,最小的一个排序更靠前 compare = taskToWeightRatio1.compareTo(taskToWeightRatio2) } if (compare < 0) { true } else if (compare > 0) { false } else { 如果两个根据上面的计算,排序值都相同,就看看这两个调度器的名称,按名称的字节序来排序了. s1.name < s2.name } } }
以上是关于spark的task调度器(FAIR公平调度算法)的主要内容,如果未能解决你的问题,请参考以下文章
Linux CFS调度器之pick_next_task_fair选择下一个被调度的进程--Linux进程的管理与调度(二十八)
Linux 内核CFS 调度器 ⑤ ( CFS 调度器类 fair_sched_class 源码 | next 赋值 | enqueue_task 赋值 | dequeue_task 赋值 )