- 接口功能:当存在TP域通信时,先进行ReduceScatterV通信,再进行AllToAllV通信,最后将接收的数据整合(乘权重再相加);当不存在TP域通信时,进行AllToAllV通信,最后将接收的数据整合(乘权重再相加)。
- 计算公式:
[object Object]
相较于[object Object]接口,该接口变更如下:
- 输入了更详细的token信息辅助
[object Object]高效地进行全卡同步,因此原接口中shape为[object Object]的[object Object]入参替换为shape为[object Object]的[object Object]参数; - 新增
[object Object]入参,支持在[object Object]为0时,由用户输入共享专家计算后的token; - 新增
[object Object]入参,代替[object Object]和[object Object]环境变量。
详细说明请参考以下参数说明。
每个算子分为两段式接口,必须先调用 “aclnnMoeDistributeCombineV2GetWorkspaceSize”接口获取计算所需workspace大小以及包含了算子计算流程的执行器,再调用“aclnnMoeDistributeCombineV2”接口执行计算。
参数说明
[object Object][object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]:
[object Object]支持nullptr、""、"fullmesh"、"hierarchy";推荐配置"hierarchy"并搭配≥25.0.RC1.1版本驱动;nullptr和""依HCCL环境变量选择算法(不推荐);"fullmesh"通过RDMA直传token;"hierarchy"经机内、跨机两次发送减少跨机数据量。- 不支持共享专家场景。
[object Object]的shape为 (moeExpertNum + 2 * globalBs * K * serverNum, ),其中K指topK个专家数,前moeExpertNum个数表示从EP通信域各卡接收的token数,后2 * globalBs * K * serverNum个数用于存储机间/机内通信前,combine可提前做reduce的token个数和通信区偏移,globalBs=0时按Bs * epWorldSize计算。- 当前不支持TP域通信。
[object Object]依commAlg取值,"fullmesh"要求为1D Tensor,shape为(Bs, );true需排在false前(例:{true, false, true}非法);"hierarchy"当前版本不支持,传空指针即可。[object Object]要求为1D Tensor,shape为 (A, )。[object Object]为预留参数,当前版本不支持,传空指针即可。[object Object]依commAlg取值,"fullmesh"支持2、3、4、5、6、7、8、16、32、64、128、192、256、384;"hierarchy"支持16、32、64。[object Object]取值范围(0, 512]。[object Object]当前版本不支持,传空字符即可。[object Object]当前版本不支持,传0即可。[object Object]当前版本不支持,传0即可。[object Object]当前版本不支持,传0即可。[object Object]当前版本不支持,传0即可。[object Object]当前版本不支持,传0即可。[object Object]取值范围0或2(0表示不量化,2表示int8量化),取值为2仅当commAlg为"hierarchy"或HCCL_INTRA_PCIE_ENABLE=1且HCCL_INTRA_ROCE_ENABLE=0且驱动版本≥25.0.RC1.1时支持。
[object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]:
[object Object]当前版本不支持,传空指针即可。[object Object]的shape为 (epWorldSize * max(tpWorldSize, 1) * localExpertNum, )。- 有TP域通信时
[object Object]为1D shape Tensor,shape为 (tpWorldSize, )。 [object Object]要求为1D或2D Tensor(1D时shape为(BS, ),2D时shape为(BS, K));1D时true需排在false前,2D时token对应K个值全为false则不参与通信。[object Object]为预留参数,当前版本不支持,传空指针即可。[object Object]要求为2D或3D Tensor(2D时shape为 (Bs, H);3D时前两位乘积等于Bs、第三维等于H);可传或不传,传入时sharedExpertRankNum需为0。[object Object]取值支持[2, 768]。[object Object]取值范围(0, 1024]。[object Object]字符串长度范围为[0, 128),不能和groupEp相同,仅在无tp域通信时支持传空。[object Object]取值范围[0, 2],0和1表示无TP域通信,有TP域通信时仅支持2。[object Object]取值范围[0, 1],同一个TP通信域中各卡的tpRankId不重复;无TP域通信时传0即可。[object Object]当前仅支持传0,表示共享专家卡排在MoE专家卡前面。[object Object]当前取值范围[0, 4]。[object Object]取值范围[0, epWorldSize);为0时需满足sharedExpertNum为0或1,不为0时需满足sharedExpertRankNum % sharedExpertNum = 0。[object Object]取值范围0或2(0表示不量化,2表示int8量化),取值为2仅当tpWorldSize < 2时可使能。
Atlas 350 加速卡:
[object Object]当前版本不支持,传空指针即可。[object Object]的shape为 (epWorldSize * max(tpWorldSize, 1) * localExpertNum, )。[object Object]当前版本不支持,传空指针即可。[object Object]要求为1D或2D Tensor(1D时shape为(BS, ),2D时shape为(BS, K));1D时true需排在false前(例:{true, false, true}非法),2D时token对应K个值全为false则不参与通信。[object Object]预留参数,当前版本不支持,传空指针即可。[object Object]要求为2D或3D Tensor(2D时shape为 (Bs, H);3D时前两位乘积等于Bs、第三维等于H);可传或不传,传入时sharedExpertRankNum需为0。[object Object]取值支持[2, 768]。[object Object]取值范围(0, 1024]。[object Object]当前版本不支持,传空字符即可。[object Object]当前版本不支持,传0即可。[object Object]当前版本不支持,传0即可。[object Object]当前仅支持传0,表示共享专家卡排在MoE专家卡前面。[object Object]当前取值范围[0, 4]。[object Object]取值范围[0, epWorldSize);为0时需满足sharedExpertNum为0或1,不为0时需满足sharedExpertRankNum % sharedExpertNum = 0。[object Object]取值范围0或2(0表示不量化,2表示int8量化)。
返回值
第一段接口完成入参校验,出现以下场景时报错:
[object Object]
确定性计算:
- aclnnMoeDistributeCombineV2默认确定性实现。
在不同产品型号、不同通信算法或不同版本中,
[object Object]的Tensor输出[object Object]、[object Object]、[object Object]、[object Object]中的元素值可能不同,使用时直接将上述Tensor传给[object Object]对应参数即可,模型其他业务逻辑不应对其存在依赖。调用接口过程中使用的
[object Object]、[object Object]、[object Object]、[object Object]、[object Object]、[object Object]、[object Object]、[object Object]、[object Object]、[object Object]参数及[object Object]取值所有卡需保持一致,网络中不同层中也需保持一致,且和[object Object]对应参数也保持一致。[object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]:该场景下单卡包含双DIE(简称为“晶粒”或“裸片”),因此参数说明里的“本卡”均表示单DIE。
参数说明里shape格式说明:
- A:表示本卡需要分发的最大token数量,取值范围如下:
- 对于共享专家,需满足 (A = Bs * epWorldSize * sharedExpertNum / sharedExpertRankNum)。
- 对于MoE专家,当
[object Object]为0时,需满足 (A >= Bs * epWorldSize * min(localExpertNum, K));当[object Object]非0时,需满足 (A >= globalBs * min(localExpertNum, K))。
- H:表示hidden size(隐藏层大小):
- [object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]:依commAlg取值,"fullmesh"支持(0, 7168]且为32的整数倍;"hierarchy"并且驱动版本≥25.0.RC1.1时支持(0, 10*1024]且为32的整数倍。
- [object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]:取值为[1024, 8192]。
- Atlas 350 加速卡:取值范围[1024, 8192]。
- Bs:表示batch sequence size(本卡最终输出的token数量):
- [object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]:依commAlg取值,"fullmesh"支持(0, 256];"hierarchy"并且驱动版本≥25.0.RC1.1时支持(0, 512]。
- [object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]:取值范围为 (0 < Bs ≤ 512)。
- Atlas 350 加速卡:取值范围为 (0 < Bs ≤ 512)。
- K:表示选取topK个专家,取值范围为 (0 < K ≤ 16) 且满足 (0 < K ≤ moeExpertNum)。
- serverNum:表示服务器的节点数,取值仅支持2、4、8。
- localExpertNum:表示本卡专家数量:
- 对于共享专家卡,(localExpertNum = 1)。
- 对于MoE专家卡,(localExpertNum = moeExpertNum / (epWorldSize - sharedExpertRankNum));当(localExpertNum > 1)时,不支持TP域通信。
- A:表示本卡需要分发的最大token数量,取值范围如下:
HCCL_BUFFSIZE:
调用本接口前需检查
[object Object]环境变量取值是否合理,该环境变量表示单个通信域占用内存大小,单位MB,不配置时默认为200MB:- [object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]:
- commAlg为""或nullptr:依HCCL环境变量选择“fullmesh”或“hierarchy”公式。
- commAlg为"fullmesh":设置大小要求 (≥ 2 * (Bs * epWorldSize * min(localExpertNum, K) * H * sizeof(uint16) + 2MB))。
- commAlg为"hierarchy":设置大小要求 (≥ (
[object Object]+[object Object]/ 4) * Align512([object Object]* ([object Object]* 2 + 16 * Align8([object Object]))) * 1B + 8MB,其中Align8(x) = ((x + 8 - 1) / 8) * 8,Align512(x) = ((x + 512 - 1) / 512) * 512)。
- [object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]:
- ep通信域内:设置大小要求 (≥ 2) 且满足 (≥ 2 * (localExpertNum * maxBs * epWorldSize * Align512(Align32(2 * H) + 44) + (K + sharedExpertNum) * maxBs * Align512(2 * H)))(
[object Object]需使用MoE专家卡的本卡专家数;[object Object];[object Object])。 - tp通信域内:设置大小要求>=A * (H * 2 + 128) * 2。
- ep通信域内:设置大小要求 (≥ 2) 且满足 (≥ 2 * (localExpertNum * maxBs * epWorldSize * Align512(Align32(2 * H) + 44) + (K + sharedExpertNum) * maxBs * Align512(2 * H)))(
- Atlas 350 加速卡:要求 (≥ aivNum * 512 + 2 * epWorldSize * BS * H * 2 * localExpertNum),其中
[object Object]表示核数,[object Object]需使用MoE专家卡的本卡专家数。
- [object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]:
HCCL_INTRA_PCIE_ENABLE和HCCL_INTRA_ROCE_ENABLE: [object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]:该环境变量不再推荐使用,建议通过
[object Object]配置为"hierarchy"。本文公式中的“/”表示整除。
通信域使用约束:
- 一个模型中的
[object Object]和[object Object]仅支持相同EP通信域,且该通信域中不允许有其他算子。 - 一个模型中的
[object Object]和[object Object]仅支持相同TP通信域或都不支持TP通信域;有TP通信域时,该通信域中不允许有其他算子。 - [object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]:一个通信域内的节点需在一个超节点内,不支持跨超节点。
- 组网约束:
- [object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]:多机场景仅支持交换机组网,不支持双机直连组网。
[object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]:
[object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]:
无需配置ranktable文件以及环境变量RANK_TABLE_FILE、FIRST_RANK_ID。
- [object Object]Atlas A2 训练系列产品/Atlas A2 推理系列产品[object Object]、[object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]、Atlas 350 加速卡:[object Object]