YARN资源调度器概述

在Hadoop生态系统中,YARN(Yet Another Resource Negotiator)作为核心资源管理平台,其架构设计将计算资源管理与作业调度解耦,形成了"全局资源管理器(ResourceManager)+节点管理器(NodeManager)+应用管理器(ApplicationMaster)"的三层架构体系。其中ResourceManager的调度器模块(Scheduler)承担着集群资源分配的中枢职能,通过动态协调容器(Container)的分配与回收,实现多租户环境下计算资源的有效利用。

YARN调度器的基本职能

资源调度器在YARN架构中主要实现三大核心功能:首先是对集群所有节点资源的全局视图维护,通过NodeManager的心跳机制实时收集各节点的CPU、内存等资源可用量;其次是按照预设策略对资源请求进行仲裁,决定将哪些Container分配给特定应用;最后还需要处理资源抢占和回收逻辑,确保高优先级任务能够及时获取所需资源。这种设计使得YARN能够支持多种计算框架(如MapReduce、Spark、Flink)并发运行,同时保证集群资源的合理分配。

主要调度器类型演进

早期YARN仅提供FIFO Scheduler这种简单的先进先出调度器,其单队列设计虽然实现简单,但无法满足多用户共享集群时的公平性需求。随着企业应用场景的复杂化,逐渐衍生出两种主流的调度器变体:

  1. 1. CapacityScheduler:由Yahoo!贡献的调度器,采用严格的队列层级结构,通过预配置的资源容量保证不同业务线获得确定性的资源配额。其设计哲学强调"资源隔离优先",适合需要强SLA保障的生产环境。
  2. 2. FairScheduler:Facebook主导开发的调度器,采用动态权重分配机制,核心思想是让所有运行中的作业能公平地共享集群资源。其弹性资源分配特性特别适合研发测试等资源需求波动大的场景。

这两种调度器虽然策略不同,但都实现了基础的资源共享机制:包括基于队列的资源隔离、用户限制管理、资源超额申请处理等共性功能。它们也都支持通过配置文件(fair-scheduler.xml或capacity-scheduler.xml)定义复杂的队列层次结构,并允许管理员动态调整队列参数而不需重启集群。

调度器的工作流程共性

当ResourceManager收到应用提交请求时,所有类型的调度器都遵循相似的决策链条:首先根据提交用户或应用标签确定目标队列,然后在队列内部按照既定策略排序待处理的应用请求,最后结合节点资源报告决定具体的Container分配方案。这个过程中,调度器需要持续跟踪各队列的资源使用量、运行中的应用数等关键指标,为后续调度决策提供依据。

值得注意的是,现代YARN调度器都实现了动态资源配置能力。例如当某个队列资源利用率持续低于阈值时,调度器可以临时将闲置资源分配给其他队列使用,这种设计显著提升了集群整体利用率。同时,它们也都支持资源抢占机制,当高优先级任务需要资源时,可以通过终止低优先级任务的Container来快速释放资源。

CapacityScheduler的工作原理与资源分配策略

三级资源分配机制解析

1. 队列选择阶段
采用基于队列资源利用率的动态评估算法。系统会实时计算每个队列的"资源使用率比值"(实际使用资源/队列容量),优先选择比值最低的队列进行资源分配。例如:

  • • 队列A配置容量为30%,当前使用率20%
  • • 队列B配置容量为40%,当前使用率35%
    此时系统会选择资源使用率比值更低的队列A(20%/30%≈66.7% < 35%/40%=87.5%)。这种设计有效防止单个队列资源过载,同时确保集群整体利用率最大化。

2. 应用选择阶段
在选定队列内部,采用改进的FIFO策略与用户资源限制相结合的混合机制。具体执行流程包括:

  • • 首先检查应用程序优先级(可通过API设置0-10的优先级)
  • • 同优先级情况下比较提交时间戳
  • • 最后应用用户资源限制规则(通过minimum-user-limit-percent参数控制单用户最低资源保障)

3. Container分配阶段
采用增量式资源分配算法,每次分配时会综合考虑:

  • • 当前节点可用资源(包括内存、CPU等)
  • • 应用程序请求的本地性级别(NODE_LOCAL/RACK_LOCAL/ANY)
  • • 队列的maximum-capacity上限(防止单个应用占用全部弹性资源)

CapacityScheduler三级资源分配流程图

 

多队列配置架构

CapacityScheduler支持树状队列层级结构,通过"root.子队列.孙队列"的路径表达式定义队列关系。典型生产环境配置包含以下关键参数:

<property><name>yarn.scheduler.capacity.root.queues</name><value>prod,dev,test</value> <!-- 第一级队列 -->
</property>
<property><name>yarn.scheduler.capacity.root.prod.queues</name><value>bi,streaming</value> <!-- 第二级队列 -->
</property>
<property><name>yarn.scheduler.capacity.root.prod.bi.capacity</name><value>60</value> <!-- 队列容量占比 -->
</property>

队列特性配置包含三个关键维度:

  1. 1. 基础资源控制
    • • capacity:队列基础资源保障(必须保证所有队列总和为100%)
    • • maximum-capacity:弹性资源上限(默认-1表示无限制)
    • • user-limit-factor:单用户可超配资源的倍数
  2. 2. 应用并发限制
    • • maximum-applications:队列最大应用数
    • • maximum-am-resource-percent:AM资源占比上限
  3. 3. 访问控制
    • • acl_submit_applications:提交权限ACL
    • • acl_administer_queue:管理权限ACL

弹性资源管理策略

当集群存在空闲资源时,CapacityScheduler通过以下机制实现资源动态分配:

  1. 1. 队列间资源共享:当父队列未达maximum-capacity时,子队列可借用父队列资源
  2. 2. 资源回收机制:当队列资源需求超过保障容量时,系统会逐步回收借出的资源
  3. 3. 优先级抢占(需显式开启):通过yarn.resourcemanager.scheduler.monitor.policies配置抢占策略

用户资源隔离实现

为防止单个用户垄断队列资源,调度器实施双重限制:

  1. 1. 静态限制:通过minimum-user-limit-percent设置用户最低资源占比(如25%)
  2. 2. 动态调整:实际限制值会根据活跃用户数自动调整。例如:
    • • 2个活跃用户时,每个用户最多获得50%资源
    • • 3个用户时上限降为33%
    • • 4个及以上用户时强制遵守25%的最低限制

高级特性支持

现代CapacityScheduler版本通过以下扩展增强管理能力:

  1. 1. 动态队列创建:支持通过REST API实时创建/修改叶队列
  2. 2. 资源预留系统:允许为重要作业预先保留资源
  3. 3. 节点标签支持:将队列与特定标签节点绑定(如GPU队列)
  4. 4. 容器更新机制:运行时动态调整容器资源规格(需应用支持)

实际案例中,某电商平台采用三级队列结构实现资源隔离:

  • • root队列划分prod(70%)和dev(30%)
  • • prod下设置order(40%)、recommend(30%)、report(30%)
  • • 通过设置order队列maximum-capacity=60%,既保障日常订单处理资源,又允许大促期间弹性扩展

这种设计在保证关键业务SLA的同时,实现了集群资源利用率从原有55%提升至82%的优化效果。

FairScheduler的工作原理与资源分配策略

FairScheduler的架构设计基础

FairScheduler作为YARN的核心调度器之一,其设计哲学源于"公平共享"理念。在架构层面,它采用分层队列结构(FSParentQueue和FSLeafQueue),每个队列通过权重(weight)参数定义资源获取比例。值得注意的是,FairScheduler管理的资源单位并非简单的内存或CPU,而是通过ResourceCalculator抽象实现的多维度资源计算,这使得它能够同时处理内存、CPU等异构资源类型的分配。

队列层级中的关键角色包括:

  • FSParentQueue:作为父队列,仅负责子队列的资源分配和调度
  • FSLeafQueue:叶子队列直接承载应用程序(FSAppAttempt)
  • FSAppAttempt:代表单个应用程序的资源请求实体

这种分层结构使得资源分配能够按照组织架构进行逻辑划分,同时保持各层级间的资源隔离性。每个队列维护着两组关键指标:Steady Fair Share(理论配额)和Instantaneous Fair Share(动态配额),前者基于静态配置计算得出,后者则根据运行时状态动态调整。

FairShareComparator排序机制解析

资源分配的核心排序逻辑由FairShareComparator实现,该比较器通过多维度指标决定任务调度优先级。其排序规则遵循以下层次结构:

  1. 1. 最小资源保障优先:比较minShare使用率(used/minShare),未满足最小配额的队列获得更高优先级
  2. 2. 公平份额保障次之:比较fairShare使用率(used/fairShare),使用率低的队列优先获取资源
  3. 3. 权重比例兜底:当上述条件相同时,权重(weight)更高的队列获得优先权

这种三级判断机制确保了资源分配的基线公平性。例如,假设队列A配置了minShare=10GB但当前仅获得5GB,而队列B已获得其minShare,则无论fairShare使用率如何,队列A都会优先获得资源分配。

FairScheduler资源分配策略示意图

 

具体实现上,FairShareComparator通过ComputeFairShares类完成实际计算。计算过程会先排除"固定资源"(Fixed队列),包括:

  • • maxShare=0的队列
  • • 计算瞬时配额时不活跃的叶子队列(无活跃应用)
  • • 权重≤0的队列

这种排除机制有效避免了无效调度开销,提升了整体调度效率。

动态资源分配策略

FairScheduler的资源分配具有显著的动态适应特征,主要体现在:

公平份额动态调整
每个心跳周期(默认500ms)都会重新计算各队列的Instantaneous Fair Share。计算时考虑:

  • • 集群总可用资源(扣除固定分配部分)
  • • 队列权重比例
  • • 队列当前活跃状态
  • • 历史资源使用情况

这种动态调整使得系统能够快速响应负载变化。例如当某个队列的应用突然终止,其释放的资源会在下一个周期自动分配给其他需求队列。

资源抢占机制
当队列长期低于其fairShare时,调度器会触发温和的资源抢占(通过ContainerPreemptor实现)。抢占策略采用"最小伤害原则":

  1. 1. 优先选择超额使用最多的队列
  2. 2. 在该队列中选择最近启动的Container
  3. 3. 通过AM协议协商释放,避免强制终止

这种机制既保证了资源分配的长期公平性,又最大限度减少了任务中断带来的性能损耗。

公平性与效率的平衡艺术

FairScheduler通过以下设计实现公平与效率的微妙平衡:

延迟调度优化
为提升数据本地性,允许应用短暂等待(默认10s)节点本地资源,而非立即分配跨节点资源。这种"有限等待"策略在公平性让步与执行效率间取得平衡,实测可降低30%以上的网络传输开销。

资源归还策略
当应用实际使用量低于分配量时,采用渐进式资源归还:

  1. 1. 先标记超额Container为"可抢占"
  2. 2. 观察实际使用模式(避免短暂波动导致的误判)
  3. 3. 通过心跳周期逐步回收

这种设计避免了频繁的资源分配震荡,维护了集群稳定性。测试表明,相比立即回收策略,这种方式能减少约40%的AM重试请求。

权重动态调整
管理员可配置队列的dynamicWeight参数,使得队列权重能根据历史使用模式自动调节。例如长期低负载的队列会获得渐进式权重提升,这种设计防止了"资源饥饿"现象,特别适合突发负载场景。

高级配置策略解析

在实际部署中,以下配置项对资源分配行为产生关键影响:

minShare与maxShare的联动

  • • minShare设为集群资源的5%-20%可有效防止重要队列完全饥饿
  • • maxShare建议设置为minShare的3-5倍,为突发负载预留空间
  • • 两者差值过小会导致调度灵活性下降,差值过大会降低公平性保障

fairSharePreemptionTimeout
这个关键参数(默认30s)控制抢占触发时机:

  • • 值越小,公平性保障越及时,但集群吞吐量下降
  • • 值越大,资源利用率越高,但可能导致临时性资源垄断
  • • 生产环境建议根据SLA要求设置在15-60秒区间

allowUndeclaredPools
启用该参数(默认false)时,系统会自动创建未声明队列,适合动态环境。但会带来两个副作用:

  1. 1. 资源分配预测性降低
  2. 2. 需要配套设置autoCreateChildQueue.maxResources限制资源滥用

性能优化实践

针对大规模集群的调优经验表明:

心跳间隔权衡

  • • 较小值(如300ms)提升调度响应速度,但增加RM负担
  • • 较大值(如1s)提高吞吐量,但可能造成资源闲置
  • • 建议根据集群规模线性调整,万级节点集群推荐800ms

异步调度优化
启用yarn.scheduler.fair.assignmultiple(默认true)允许单次心跳分配多个Container,可降低20%-50%的调度延迟。但需要配合设置:

<property><name>yarn.scheduler.fair.max.assign</name><value>3</value> <!-- 每次心跳最大分配数 -->
</property>

内存计算优化
对于内存密集型负载,建议启用DominantResourceCalculator:

<property><name>yarn.scheduler.fair.resource-calculator</name><value>org.apache.hadoop.yarn.util.resource.DominantResourceCalculator</value>
</property>

这能更准确反映应用的真实资源需求,避免CPU空闲但内存耗尽导致的假性资源不足。

核心区别对比分析

资源分配策略差异

队列资源定义机制

CapacityScheduler采用百分比定义队列资源,同一父队列下子队列的容量总和必须严格等于100%。这种设计在集群扩容时会自动按比例分配新增资源,例如当集群新增节点后,每个队列获得的绝对资源量会同步增加。但这也可能导致业务队列获得超出实际需求的资源量,如参考资料中提到的案例:"当集群中有新的节点加入时,队列资源随着增大,但业务上该队列可能不需要更大资源"(CSDN,2021)。

FairScheduler则采用固定值定义资源配额(如vcores=10,memory-mb=20GB),通过XML配置文件明确指定最大资源量。这种机制能精确控制队列资源上限,避免资源过度分配,但需要人工调整资源配置以适应集群规模变化。腾讯云开发者社区(2021)指出:"FairScheduler的队列资源最大大小是固定可控的",这种特性在需要严格资源隔离的场景中更具优势。

调度算法实现

CapacityScheduler采用三级资源分配策略:首先通过深度优先遍历选择资源利用率最低的叶子队列,然后按照FIFO原则选择该队列中最早提交的应用程序,最后为应用分配优先级最高的Container。其默认使用DefaultResourceCalculator仅考虑内存资源,也可配置DominantResourceCalculator实现基于DRF算法的多维度资源调度。

FairScheduler则采用基于缺额(Deficit)的公平调度算法,通过FairShareComparator动态计算作业的资源缺额,优先调度缺额最大的作业。这种算法能实现更细粒度的资源公平分配,如参考资料所述:"公平是通过作业缺额体现的,调度器每次选择缺额最大的job"(CSDN,2018)。当队列配置了最小资源保障(minShare)时,系统会优先满足该保障值再进行公平分配。

适用场景对比

CapacityScheduler的最佳实践
  1. 1. 企业级多租户环境:由于其严格的队列容量隔离和Ranger集成特性,特别适合需要强资源保障的金融、电信等行业。如某银行案例中,通过节点标签功能将重要业务队列绑定到特定高性能节点组。
  2. 2. 动态扩展集群:百分比资源配置方式天然适应云环境弹性伸缩,微软在25万节点规模的YARN部署中就采用了CapacityScheduler(腾讯云,2021)。
  3. 3. 批处理密集型负载:其FIFO子队列策略对Hive、Spark SQL等批处理作业的吞吐量优化效果显著,测试显示全局调度改进后容器分配速率提升40%(VolcEngine,2023)。
FairScheduler的典型场景
  1. 1. 研发测试环境:公平分配机制能有效防止测试任务饿死,当产品队列设置minShare后,测试队列可弹性使用剩余资源。
  2. 2. 交互式分析场景:如Impala、Presto等即时查询工具,FairScheduler的快速资源归还机制能减少查询延迟。Facebook开发该调度器的初衷就是解决Hive交互查询的资源竞争问题。
  3. 3. 混合负载集群:对既有长期运行批处理作业又有临时交互任务的场景,其动态权重调整功能(weight参数)可实现灵活的资源调配。

功能特性比较

高级功能支持

CapacityScheduler在Hadoop 3.x后引入多项企业级功能:

  • 节点标签(Node Labels):通过物理划分节点资源池实现硬隔离,某电商平台利用此功能将GPU节点专供机器学习队列使用。
  • 全局调度框架:支持单次心跳周期内分配多个容器,实测在20,000节点环境中调度吞吐量提升3倍(VolcEngine,2023)。
  • 资源预留(Reservation):可提前为关键任务预留资源,避免资源碎片问题。

FairScheduler则更侧重灵活性:

  • 多级资源抢占:支持基于队列层级和用户权重的多层次抢占策略。
  • 动态队列创建:通过API可实时创建临时队列,适合短期分析项目。
  • 混合调度策略:允许不同队列配置FIFO/FAIR/DRF等不同策略,如某科研机构在同一个集群中为计算化学队列配置DRF,而为生物信息队列配置FAIR。
配置管理差异

CapacityScheduler采用层级properties文件配置,队列容量必须满足∑child=100%的硬性约束。这种设计虽然降低了配置灵活性,但能预防资源分配冲突。如开发者反馈:"同一父队列下的同一级别子队列Capacity之和必须为100,比较麻烦"(CSDN,2021)。

FairScheduler使用XML配置格式,允许子队列资源总和超过父队列容量,通过maxResources参数实现软限制。其配置项更丰富,包括:

<queue name="research"><minResources>10000 mb,10vcores</minResources><maxResources>50000 mb,50vcores</maxResources><maxRunningApps>20</maxRunningApps><schedulingPolicy>fair</schedulingPolicy>
</queue>

性能与限制分析

吞吐量表现

大规模基准测试显示,CapacityScheduler在超大规模集群中表现更优:

  • • 微软Hydra项目实测单集群5万节点环境下,CapacityScheduler实现每秒40,000+容器分配(腾讯云,2021)。
  • • 全局调度优化(YARN-5139)后,锁竞争减少使调度延迟降低60%。

FairScheduler在中小规模集群(<1000节点)中响应更快:

  • • 公平算法使短作业平均完成时间缩短35%(CSDN,2018)。
  • • 但队列层级超过5级时,缺额计算会显著增加调度开销。
已知局限性

CapacityScheduler的不足包括:

  • • 队列结构调整需要重启ResourceManager。
  • • 复杂队列树可能导致资源碎片,需配合预留系统使用。

FairScheduler的缺陷主要有:

  • • 缺乏对节点标签的支持,难以实现物理资源隔离。
  • • 动态权重调整可能引发"振荡"问题,需要精细调优权重衰减参数。

实际应用场景与案例分析

企业级集群的典型选择差异

在超大规模生产环境中,调度器的选择往往与集群管理复杂度直接相关。某互联网公司CDH集群迁移案例显示,当物理节点规模突破千台、计算内存达到150TB+时,Fair Scheduler在动态负载均衡方面展现出独特优势。该集群原先采用CDH默认的Fair Scheduler,在处理突发性分析任务时,能够自动平衡不同业务线的资源占用,确保临时高优先级查询不会阻塞常规ETL流程。但迁移到自建Hadoop3集群时,技术团队最终选择了Capacity Scheduler,主要考量是其与Node Labels机制的深度集成,能够通过标签实现GPU节点与CPU节点的精确隔离。

这种选择反映了两种典型场景:

  • 需要弹性资源共享的混合工作负载环境(如临时分析+常规批处理)更适合Fair Scheduler
  • 需要严格资源隔离的多租户环境(如不同部门共享集群)更倾向Capacity Scheduler

FairScheduler与CapacityScheduler应用场景对比

 

云原生环境下的性能表现

微软Hydra项目的测试数据揭示了调度器性能的临界点。在超过5万个节点的大型联邦集群中,Capacity Scheduler展现出每秒40k+容器的分配能力,这得益于其全局调度框架(YARN-5139)对锁机制的优化。具体表现为:

  1. 1. 解耦的放置决策:允许并行评估多个节点
  2. 2. 改进的线程模型:减少资源争用
  3. 3. 批量节点查找:提升容器分配吞吐量

相比之下,Fair Scheduler在中等规模集群(200-500节点)的测试中,对短期任务的响应延迟比Capacity Scheduler低15%-20%,这与其基于内存使用比率的调度算法(used_memory/minShare)密切相关。某电商大促期间的监控数据显示,当瞬时提交数百个实时计算任务时,Fair Scheduler能将任务完成时间的标准差控制在Capacity Scheduler的60%以内。

多租户场景的配置实践

金融行业的一个典型案例展示了队列配置的关键差异。某银行采用Capacity Scheduler时,其风险计算队列(30%资源)与客户画像队列(50%资源)的配置必须严格满足同级队列容量总和为100%的约束。这导致非高峰时段风险计算队列的闲置资源无法被画像队列充分利用,直到通过"弹性队列容量"特性实现跨队列资源共享。

而同一机构在测试环境使用Fair Scheduler时,通过权重配置(weight=2.0)使实时交易分析队列获得双倍于批量处理队列的资源,同时不需要严格的比例限制。这种灵活性使得在突发市场行情下,系统能自动调整资源分配而不需要管理员干预。但值得注意的是,Fair Scheduler的XML配置格式相比Capacity Scheduler的键值对配置更复杂,某次生产事故分析显示,错误的嵌套队列标签导致过20%的资源分配失效。

混合工作负载的调度效果

视频处理公司的A/B测试数据提供了直观对比。当使用Capacity Scheduler时:

  • • 4K转码任务的平均完成时间稳定在±5%波动范围内
  • • 但突发性短视频审核任务排队延迟高达30分钟

切换到Fair Scheduler后:

  • • 审核任务延迟下降至8分钟
  • • 转码任务完成时间波动扩大至±15%
  • • 整体集群利用率提升12%

这种差异本质上源于两者的设计哲学:Capacity Scheduler的"容量保证"特性确保关键业务不受干扰,而Fair Scheduler的"动态权重调整"更适应负载变化。某跨国企业的解决方案是混合部署——在核心数据仓库使用Capacity Scheduler保证日批处理SLA,同时在临时分析集群采用Fair Scheduler提升资源周转率。

技术栈整合的现代趋势

Cloudera CDP的演进方向值得关注。其放弃Fair Scheduler转而全面支持Capacity Scheduler的决策基于三点技术考量:

  1. 1. 与Ranger的细粒度权限集成:实现队列访问的列级控制
  2. 2. 云原生适配性:支持自动扩展和bin-packing策略
  3. 3. 节点分区管理:通过标签实现异构资源调度

但开源社区仍保留Fair Scheduler的原因在于其独特的"资源借贷"机制。某AI公司的实验显示,当训练任务突发增长时,Fair Scheduler能自动将空闲的推理资源重新分配,而Capacity Scheduler需要预先设置弹性容量参数。这种差异使得Fair Scheduler在算法研发等非标准化场景中仍不可替代。

面试常见问题与解答

资源分配策略的核心差异问题

Q1:CapacityScheduler和FairScheduler在空闲资源分配时的决策逻辑有何本质区别?
A1:CapacityScheduler采用三级资源分配策略,优先选择资源占用率最低的叶子队列(通过深度优先遍历),再选择最早提交的应用程序(FIFO原则),最后根据本地性选择Container。而FairScheduler使用FairShareComparator动态计算队列/应用的资源使用比例(used_memory/minShare),优先分配资源给使用率最低的实体。例如,当集群有空闲资源时,CapacityScheduler会严格遵循队列容量限制,而FairScheduler允许临时借用其他队列的闲置资源。

Q2:两者如何实现多租户场景下的资源隔离?
A2:CapacityScheduler通过硬性容量限制(如队列A固定分配30%集群资源)实现强隔离,适合生产环境中的SLA保障;FairScheduler则采用弹性权重(weight参数),允许队列按比例动态共享资源,更适合临时性分析任务。例如,在腾讯云实践中,金融客户通常选择CapacityScheduler确保稳定性,而科研团队偏好FairScheduler的灵活性。

调度策略与高级特性对比

Q3:两种调度器分别支持哪些资源比较算法?
A3:CapacityScheduler默认使用DefaultResourceCalculator(仅内存),但可配置为DominantResourceCalculator(DRF算法,同时考虑CPU/内存);FairScheduler原生集成DRF,还支持FIFOFAIR策略混合使用。例如在阿里云案例中,混合负载集群会启用DRF以避免CPU密集型任务垄断资源。

Q4:资源抢占机制的实现有何不同?
A4:CapacityScheduler的抢占基于队列容量保障,当某个队列资源使用低于配置值时触发;FairScheduler的抢占则聚焦公平性阈值(通过fairSharePreemptionThreshold参数控制)。实际测试表明,FairScheduler的抢占响应更快(平均2-3秒),但可能引发更多任务重启。

配置与性能调优问题

Q5:如何根据业务需求选择调度器?
A5:关键考虑三点:

  1. 1. 业务类型:长期运行服务(如HBase)选CapacityScheduler,临时分析作业选FairScheduler
  2. 2. 隔离需求:严格SLA要求必须用CapacityScheduler
  3. 3. 资源利用率:FairScheduler在集群负载波动大时利用率更高
    参考华为大数据团队测试数据,FairScheduler在突发负载下资源利用率比CapacityScheduler高15%-20%。

Q6:配置队列层级时有哪些注意事项?
A6:CapacityScheduler要求预定义静态队列,修改需重启ResourceManager;FairScheduler支持动态队列创建(通过配置文件热加载)。典型错误案例包括:在CapacityScheduler中未设置子队列容量导致父队列资源浪费,或在FairScheduler中未合理设置minShare导致小作业饿死。

底层实现原理剖析

Q7:为什么YARN的事件驱动模型会影响调度器设计?
A7:YARN的异步事件处理机制要求调度器实现必须非阻塞。CapacityScheduler采用增量式分配(每次处理一个NodeManager的心跳),而FairScheduler引入连续分配模式(一次心跳分配多个Container)。这在源码层面体现为:FairScheduler的FSAppAttempt类包含更复杂的资源记账逻辑。

Q8:如何解释两个调度器同质化现象?
A8:随着Hadoop版本迭代,两者功能逐渐趋同(如都支持层级队列、DRF算法)。但核心差异仍在设计哲学:CapacityScheduler以队列为中心保障稳定性,FairScheduler以应用为中心追求弹性。实际选型时,新版本(Hadoop 3.0+)建议优先测试FairScheduler,因其功能已覆盖CapacityScheduler大部分特性。


引用资料

[1] : https://cloud.tencent.com/developer/article/1194446

[2] : https://www.cnblogs.com/jpSpaceX/articles/15032880.html

[3] : https://community.transwarp.cn/article/1194

[4] : https://blog.csdn.net/weixin_46376562/article/details/125855125

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/news/916343.shtml
繁体地址,请注明出处:http://hk.pswp.cn/news/916343.shtml
英文地址,请注明出处:http://en.pswp.cn/news/916343.shtml

如若内容造成侵权/违法违规/事实不符,请联系英文站点网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

基于Seata的微服务分布式事务实战经验分享

基于Seata的微服务分布式事务实战经验分享 1. 业务场景描述 在电商系统中&#xff0c;用户下单会涉及多个微服务&#xff1a;订单服务&#xff08;Order Service&#xff09;、库存服务&#xff08;Inventory Service&#xff09;、账户服务&#xff08;Account Service&#x…

Linux库——库的制作和原理(2)_库的原理

文章目录库的原理理解目标文件ELF文件读取ELF的工具——readelfELF从形成到加载的轮廓ELF形成可执行文件ELF可执行的加载理解链接与加载静态链接ELF加载和进程地址空间虚拟地址 & 逻辑地址重新理解进程地址空间动态链接和动态库的加载进程如何找到动态库多个进程之间如何共…

Redis C++客户端——通用命令

目录 代码案例 get和set部分 exists部分 del部分 keys部分 expire部分 type部分 本篇文章主要是通过redis-plus-plus库使用通用命令。 代码案例 下面用一个代码演示&#xff1a; #include <sw/redis/redis.h> #include <iostream> #include <vecto…

手机开启16k Page Size

我买了一个pixel8的手机&#xff0c;系统是Android16,如下操作都是基于这个手机做的。 https://source.android.com/docs/core/architecture/16kb-page-size/16kb-developer-option?hlzh-cn#use_16kb_toggle 使用 16 KB 切换开关 按照开发者选项文档中的指示启用开发者选项。…

VLAN的划分(基于华为eNSP)

VLAN的划分 前言&#xff1a;为什么VLAN是现代网络的“隐形骨架”&#xff1f; 当一台办公室电脑发送文件给隔壁工位的同事时&#xff0c;数据如何精准抵达目标而不“打扰”其他设备&#xff1f;当企业财务部的敏感数据在网络中传输时&#xff0c;如何避免被其他部门的设备“窥…

从压缩到加水印,如何实现一站式图片处理

当你需要对大量图片进行相同或相似的操作时&#xff08;例如压缩、裁剪、调整尺寸、添加水印等&#xff09;&#xff0c;逐个处理会非常耗时。批量处理工具可以一次性处理数百张图片&#xff0c;大大节省了时间。这是一款极致轻巧的图片处理利器&#xff0c;体积仅有652KB&…

Pythong高级入门Day5

二、面向对象编程面向对象编程&#xff08;Object-Oriented Programming&#xff0c;简称OOP&#xff09;是一种通过组织对象来设计程序的编程方法。Python天生就是面向对象的模块化编程。1. 初识类和对象示意图&#xff1a;/-------> BYD E6(京A.88888) 实例&#xff0c;对…

C#其他知识点

接口类---interface什么是接口? 在接口当中一般我们认为接口中的成员都是抽象的。接口一般认为是功能的集合。在接口类当中定义的方法都是抽象象方法。(没有方法体)接口一般我们认为它是一种标准,一种规范,一种约定。给子类或者是派生类制定规范,规定,标准。当子类继承了该接口…

Maven 环境配置全攻略:从入门到实战

一、Maven 简介 Maven 是一个基于项目对象模型 (POM) 的项目管理工具&#xff0c;它可以通过一小段描述信息来管理项目的构建、报告和文档。 除了强大的程序构建能力外&#xff0c;Maven 还提供了高级项目管理功能。其默认构建规则具有很高的可重用性&#xff0c;通常只需两三…

现代 C++ 开发工作流(VSCode / Cursor)

✅ 推荐的现代 C 开发工作流&#xff08;含 VSCode / Cursor 插件配置&#xff09;&#x1f9f0; 一、环境要求 C 编译器&#xff08;如 g 或 clang&#xff09;CMake&#xff08;建议 ≥ 3.16&#xff09;clangd&#xff08;建议 ≥ 14&#xff0c;最好用系统包管理器安装&…

[SAP ABAP] ALV报表练习4

SO销售订单明细报表业务目的&#xff1a;根据选择屏幕的筛选条件&#xff0c;使用ALV报表显示销售订单详情(Sales Order、Material、现有Qty、已开立数量以及剩余数量等)信息效果展示我们在销售订单栏位输入需要查询的SO单号&#xff0c;这里我们以SO单号0000000221为例&#x…

《设计模式之禅》笔记摘录 - 10.装饰模式

装饰模式的定义装饰模式(Decorator Pattern)是一种比较常见的模式&#xff0c;其定义如下&#xff1a;Attach additional responsibilities to an object dynamically keeping the same interface. Decorators provide a flexible alternative to subclassing for extending fu…

[AI8051U入门第十步]W5500-客户端

学习目标: 1、认识W5500模块 2、驱动W5500静态获取ip 3、获取全球唯一码作为mac地址 4、拔出网线重插网线自动获取IP 5、编写W5500作为客户端进行TCP/IP代码一、W5500介绍 W5500 是一款由韩国 WIZnet 公司推出的高性能 硬件 TCP/IP 嵌入式以太网控制器,专为嵌入式系统设计,…

UNETR++: Delving Into Efficient and Accurate 3D Medical Image Segmentation

摘要得益于Transformer模型的成功&#xff0c;近期研究开始探索其在3D医学分割任务中的适用性。在Transformer模型中&#xff0c;自注意力机制是核心构建模块之一&#xff0c;与基于局部卷积的设计相比&#xff0c;它致力于捕捉长距离依赖关系。然而&#xff0c;自注意力操作存…

Kotlin Flow 在 Jetpack Compose 中的正确打开方式:SharedFlow vs StateFlow 与 LaunchedEffect

在 Jetpack Compose 中&#xff0c;Kotlin Flow 是处理异步数据流的核心工具&#xff0c;而 SharedFlow 和 StateFlow 是最常用的两种 Flow 类型。但很多开发者对它们的适用场景、如何与 LaunchedEffect 配合使用存在困惑。本文将深入探讨它们的区别&#xff0c;并给出最佳实践…

嵌入式——C语言:指针①

一、指针特点1.让代码更加简洁高效2.提供直接访问内存的操作3.利用指针可以直接操作硬件二、指针概念&#xff08;一&#xff09;地址&#xff1a;为了区分内存中不同字节的编号&#xff08;0到2^16-1&#xff09;&#xff08;二&#xff09;指针&#xff1a;指针就是地址&…

RabbitMQ—HAProxy负载均衡

上篇文章&#xff1a; RabbitMQ—仲裁队列https://blog.csdn.net/sniper_fandc/article/details/149312579?fromshareblogdetail&sharetypeblogdetail&sharerId149312579&sharereferPC&sharesourcesniper_fandc&sharefromfrom_link 目录 1 HAProxy安装…

QT中启用VIM后粘贴复制快捷键失效

当在QT中启用FakeVim之后&#xff0c;Ctrl C 和 Ctrl V 快捷键就变成 Vim 的快捷键了&#xff0c;我希望它还是原来的复制粘贴功能&#xff0c;打开&#xff1a;编辑 > Preferences…&#xff0c;然后勾选 “Pass control keys”即可&#xff0c;如下&#xff1a;

TCP三次握手与四次挥手全解析

&#x1f30a; TCP三次握手与四次挥手全解析&#xff08;含序列号动态追踪&#xff09;&#x1f511; TCP 协议核心机制 序列号 (seq)&#xff1a;数据字节流的唯一标识&#xff08;32位循环计数器&#xff09;确认号 (ack)&#xff1a;期望接收的下一个序列号&#xff08;ack …

7月26号打卡

作业&#xff1a;题目1&#xff1a;计算圆的面积 任务&#xff1a; 编写一个名为 calculate_circle_area 的函数&#xff0c;该函数接收圆的半径 radius 作为参数&#xff0c;并返回圆的面积。圆的面积 π * radius (可以使用 math.pi 作为 π 的值)要求&#xff1a;函数接收一…