Your current environment
See as below.
🐛 Describe the bug
Dear all,
we are trying to run large-scale EP (across DP) with DeepEP, using the deepep dockerfile provided by SGLang.
testbed: 2 nodes, each with 8 GPUs (H20-141 GB). mlx5 IB card with IBGDA enabled.
model: deepseek_r1
We have nvidia_peermem and gdr driver installed in the host.
We can successfully run DeepEP internode benchmark with high_throughput and low_latency kernels (IBGDA enabled).
However, when we are running vLLM-v0.9.2 dp=2, tp=8, ep=16, with all2all backend set to deepep_low_latency or deepep_high_throughput. We found the process hangs when doing warm-up requests.
The script we use is offline_inference/data_parallel.py.
We trace the code and find that the first MoE layer can complete the dispatch -> expert compute -> combine process. But in the second MoE layer, workers hang when calling dispatch (here) and the whole task will timeout after 5 minutes. Surprisingly, when we torch up the code a bit to skip the combine process, the task can complete.
We also find using PPLX hangs in the same place. But using naive all2all impl (i.e., broadcast + allreduce) works fine.
More information: we integrate DeepEP by ourselves in v0.8.4, and can run normally using offline DP example in the same environment. When it comes to the community version after v0.9.1, this bug occurs. Is that due to the development of online DP?
We would greatly appreciate it if you have any hints on debugging this problem. It stucks us for weeks.
Please let me know if more information is needed. Many thanks!
Running command:
VLLM_WORKER_MULTIPROC_METHOD=spawn \
VLLM_ALL2ALL_BACKEND=deepep_high_throughput \
NVSHMEM_HCA_LIST=mlx5_2 \
NVSHMEM_BOOTSTRAP_UID_SOCK_IFNAME=eth0 \
NCCL_SOCKET_IFNAME=eth0 \
GLOO_SOCKET_IFNAME=eth0 \
NCCL_IB_HCA=mlx5_2 \
python examples/offline_inference/data_parallel.py \
--model="/vllm-workspace/models/DeepSeek-V3-0324" \
--dp-size=2 \
--tp-size=8 \
--node-size=2 \
--node-rank=0 \
--master-addr=xxx.xxx.xxx.xxx \
--master-port=12768
VLLM_WORKER_MULTIPROC_METHOD=spawn \
VLLM_ALL2ALL_BACKEND=deepep_high_throughput \
NVSHMEM_HCA_LIST=mlx5_2 \
NVSHMEM_BOOTSTRAP_UID_SOCK_IFNAME=eth0 \
NCCL_SOCKET_IFNAME=eth0 \
GLOO_SOCKET_IFNAME=eth0 \
NCCL_IB_HCA=mlx5_2 \
python examples/offline_inference/data_parallel.py \
--model="/vllm-workspace/models/DeepSeek-V3-0324" \
--dp-size=2 \
--tp-size=8 \
--node-size=2 \
--node-rank=1 \
--master-addr=xxx.xxx.xxx.xxx \
--master-port=12768
The output screenshot:

Before submitting a new issue...
Your current environment
See as below.
🐛 Describe the bug
Dear all,
we are trying to run large-scale EP (across DP) with DeepEP, using the deepep dockerfile provided by SGLang.
testbed: 2 nodes, each with 8 GPUs (H20-141 GB). mlx5 IB card with IBGDA enabled.
model: deepseek_r1
We have
nvidia_peermemandgdr driverinstalled in the host.We can successfully run DeepEP internode benchmark with high_throughput and low_latency kernels (IBGDA enabled).
However, when we are running vLLM-v0.9.2
dp=2, tp=8, ep=16, with all2all backend set todeepep_low_latencyordeepep_high_throughput. We found the process hangs when doing warm-up requests.The script we use is offline_inference/data_parallel.py.
We trace the code and find that the first MoE layer can complete the
dispatch -> expert compute -> combineprocess. But in the second MoE layer, workers hang when callingdispatch(here) and the whole task will timeout after 5 minutes. Surprisingly, when we torch up the code a bit to skip thecombineprocess, the task can complete.We also find using PPLX hangs in the same place. But using naive all2all impl (i.e., broadcast + allreduce) works fine.
More information: we integrate DeepEP by ourselves in v0.8.4, and can run normally using offline DP example in the same environment. When it comes to the community version after v0.9.1, this bug occurs. Is that due to the development of online DP?
We would greatly appreciate it if you have any hints on debugging this problem. It stucks us for weeks.
Please let me know if more information is needed. Many thanks!
Running command:
The output screenshot:

Before submitting a new issue...