现在的位置: 首页 > 综合 > 正文

hadoop资源感知

2018年03月18日 ⁄ 综合 ⁄ 共 1687字 ⁄ 字号 评论关闭

原文:http://dongxicheng.org/mapreduce/hadoop-resource-aware-scheduler/


1. 什么是Hadoop资源感知调度器?

Hadoop资源感知调度器是指调度器根据各个TaskTracker当前资源负载情况(cpu,内存,网络io等)动态决定将新任务调度给哪个节点处理。

2. Hadoop资源感知调度器的必要性和重要性

当前绝大多数Hadoop调度器是按照slot多少进行调度。在Hadoop中,存在两种slot:map slot和reduce slot,每个节点可以根据自己实际的CPU个数配置slot个数,一次配好后,启动Hadoop便不可修改。 一旦某个节点上出现空闲的slot,调度器便会分配一个task给该节点。Slot类似于令牌,map task需要拿到一个map slot才可运行,类似,reduce task需要拿到一个reduce slot才可运行,如果当前所有slot都被task占用了,则剩下的task需要排队。

了解当前调度器的基本原理后,便会发现当前调度器存在很大缺陷。调度器的基本作用是:为需要计算机资源的任务分配资源,使他们能够顺利完成计算任务。这里的计算机资源包括cpu,内存,网络,磁盘等,而当前所有调度器几乎只考虑了cpu资源,这就导致TaskTracker经常出现OOM或者网络阻塞等现象,严重时,可能会把机器搞挂!

3. 如何设计资源感知调度器?

Hadoop调度器模型实际上是一个典型的任务指派模型,即:资源量是M,任务数是N,如果将这M个资源分配给这N个任务,使他们尽可能利用所有资源,尽快完成任务。

为了实现该模型,一个Hadoop资源感知调度器需要包括四个模块:

(1) 信息采集模块

各个TaskTracker周期性的采集本节点上的资源信息,这些信息主要由两部分组成:机器总体资源和每个task资源使信息,这里的资源信息包括cpu使用情况,内存使用情况,网络和磁盘情况等。为了减少获取资源的代价,可以从linux 虚拟文件系统/proc目录下获取;

(2) 信息传输模块

TaskTracker采集的资源信息通过heartbeat发送给JobTracker,默认情况下,heartbeat发送周期是3s。完了完成该模块,需要稍微修改一下Hearbeat包;

(3) 信息聚集模块

JobTracker收集到信息后,会进行聚集,如:以job为单位做统计等;

(4) 作业调度模块

调度器从JobTracker上获取各个节点资源使用情况,并以此制定调度策略。

4. 资源感知调度器难度在哪?

Hadoop感知调度器最大难度在于调度,这实际上一个多目标决策问题,理论上没有最优解,一般需要设计启发式算法

5. 资源感知调度器方面的资料

(1)https://issues.apache.org/jira/browse/MAPREDUCE-220

(2)论文:Towards a Resource Aware Scheduler in Hadoop http://www-personal.umich.edu/~shiwali/images/hadoop.pdf

(3)Multiple-Job Optimization in MapReduce for Heterogeneous Workloads

Weisong Hu; Chao Tian; Xiaowei Liu; Hongwei Qi; Li Zha; Huaming Liao; Yuezhuo Zhang; Jie Zhang;

Semantics Knowledge and Grid (SKG), 2010 Sixth International Conference on

6. 说明

Hadoop自带的Capacity Scheduler能够调度大内存任务,原理是:默认情况下每个slot对应一个内存量,当用户提交作业时,需配置一个task需要的内存量,然后两个值相除取丄整便得到了一个task对应的slot数。如:你提交了一个作业,告诉调度器一个task要使用4GB内存,而默认情况下一个slot对应2GB内存,则没运行一个你的task,会使用2个slot

抱歉!评论已关闭.