Spark动态分配与executorAllocationRatio的作用及配置疑问
Spark中executorAllocationRatio的作用及配置疑问解答
一、executorAllocationRatio的核心作用
spark.dynamicAllocation.executorAllocationRatio是Spark动态资源分配模式下的关键参数,用于限制作业对集群总资源的利用率占比。它的作用逻辑是:
- 先基于集群总可用核心数,乘以该比例得到作业可使用的最大核心数上限
- 再结合
spark.executor.cores的配置,计算出作业能分配的最大执行器数量(最大核心数上限 / 单执行器核心数) - 注意:该参数仅影响执行器的数量范围,不会改变单个执行器的核心数配置。
二、针对给定配置的疑问解答
先明确给定的Spark配置(已整理格式):
"spark.dynamicAllocation.enabled": "true", "spark.dynamicAllocation.executorAllocationRatio": "0.4", "spark.executor.cores": "5", "spark.dynamicAllocation.minExecutors": "6", "spark.dynamicAllocation.maxExecutors": "30", "spark.executor.instances": "30"
注:开启动态分配后,spark.executor.instances配置会被忽略,执行器数量由动态分配逻辑接管。
疑问1:作业启动时的最小执行器和核心数
spark.dynamicAllocation.minExecutors是动态分配的硬下限,executorAllocationRatio不会对最小值产生影响。所以作业启动时会直接分配6个执行器,每个执行器使用5核,总计30核。
疑问2:动态分配是否会影响核心数
不会。spark.executor.cores设定的是单个执行器固定使用的核心数,动态分配仅会在minExecutors和maxExecutors的范围内调整执行器的数量,单个执行器的核心数始终保持为5,不会低于这个值。executorAllocationRatio只是用来约束作业能申请的最大核心数上限,进而限制最大执行器数量,和单执行器核心数无关。
内容的提问来源于stack exchange,提问作者Matthew
相关产品推荐
相关产品推荐

