阶段状态:等待真实双 Rail RDMA 重跑。
启动器与静态验证已完成;历史无效 Run 不进入最终分析。下一次仅在
NCCL 日志通过 NET/IB 门禁后执行 Sanity 和完整 quick map。
1. 目标与边界
用数小时以内、可重复的小矩阵替代约一天以上的全量扫描,先回答 Prefill、Decode、长上下文和混合干扰各自是否存在明显异常,再决定后续 Timeline 和 Kernel Profiling 的捕获对象。该阶段不要求为了“跑满表格” 而浪费算力;一旦出现稳定、可复现且足以改变调查方向的异常,就可以提前结束。
- 只测试 SGLang,不测试 vLLM。
- 使用双机 16 卡完整实例,不做 PD 分离。
- 不启用 MTP、EAGLE、DSpark 或其他投机解码。
- 本轮不启用 Profiler;正文只记录最终有效 Run,失败尝试仅在末尾总结经验。
- 不修改或调用旧的全天全量 Benchmark 脚本。
2. 精简实现
实验代码位于:
/data/hzy/sskj/experiments/pro6000/
dsv4pro_pro6000d_2node_sglang_tp16_quick_map/
| 文件 | 职责 |
|---|---|
run_quick_map.sh |
唯一 Shell 入口:双机服务启停、固定矩阵、混合 A/B、错误处理与清理 |
config.env |
节点、模型、镜像、并行与容量参数 |
quick_map_scenarios.tsv |
九个固定工作负载点 |
quick_map_results.py |
验证 Bench JSON,生成 CSV、JSONL 和 Markdown 汇总 |
tests/test_quick_map_results.py |
结果解析回归测试 |
单入口的操作面:
bash run_quick_map.sh all
# 仅排障时使用同一个入口
bash run_quick_map.sh start
bash run_quick_map.sh fixed
bash run_quick_map.sh mixed
bash run_quick_map.sh stop
3. 服务配置
| 配置项 | 当前值 | 说明 |
|---|---|---|
| 镜像 | lmsysorg/sglang:nightly-dev-cu13-20260720-b3570a45 |
沿用已验证可加载 DSV4-Pro 的版本 |
| 模型 | /data/hf_models/DeepSeek-V4-Pro |
两台节点均有本地权重 |
| 并行 | TP=16, EP=2, nnodes=2 |
每台 8 卡,共 16 Rank |
| 显存比例 | 0.9 |
保持已知基线,不在本阶段调参 |
| 活跃请求上限 | 256 |
覆盖本轮最大并发 64 |
| CUDA Graph Decode BS | 64 |
覆盖固定矩阵中的 Decode C64 |
| NCCL Socket 接口 | eth0 |
RDMA 失败回退时也承载跨机 Tensor,不只是 bootstrap |
| RoCE HCA | mlx5_0,mlx5_3 |
启动器只透传对应的 uverbs0/uverbs3 与 rdma_cm |
| 传输后端门禁 | REQUIRE_NCCL_IB=1 |
两端日志未证明 NET/IB + mlx5_0 + mlx5_3 时禁止开始 benchmark |
| 代码分支 | hzy |
从该维护分支向中央仓库 main 提交合并请求 |
4. 固定快速矩阵
| Case ID | ISL | OSL | C | 目的 |
|---|---|---|---|---|
short_prefill_latency_1k_c1 | 1K | 1 | 1 | 最小 TTFT |
mid_prefill_latency_32k_c1 | 32K | 1 | 1 | 中长 Prefill |
long_prefill_latency_128k_c1 | 128K | 1 | 1 | 长上下文 Prefill |
mid_prefill_throughput_32k_c16 | 32K | 1 | 16 | Prefill 输入吞吐 |
decode_latency_1k_to_1k_c1 | 1K | 1K | 1 | 单请求 TPOT |
decode_throughput_1k_to_1k_c16 | 1K | 1K | 16 | Decode 吞吐 |
decode_throughput_1k_to_1k_c32 | 1K | 1K | 32 | Decode 吞吐 |
decode_throughput_1k_to_1k_c64 | 1K | 1K | 64 | Decode 高并发 |
balanced_32k_to_1k_c8 | 32K | 1K | 8 | 综合压力 |
快速 Run 使用一次重复和一波测量请求,即 num_prompts=C。
32K/128K Prefill 不做昂贵的同形状 Warm-up;短 Prefill 与 Decode 使用一个
Warm-up,并在正式计时前清空 Prefix Cache。固定矩阵不做 SLO 截断或自适应并发搜索。
5. SGLang Benchmark 与 Prefix Cache
5.1 random 如何生成 ISL
当前镜像的实现位于
/sgl-workspace/sglang/python/sglang/benchmark/datasets/random.py。
dataset-name=random 会读取 ShareGPT,打乱样本后取每条会话的首轮用户文本:
文本过长就截断,过短就重复其 token,直到达到目标 ISL。
random-range-ratio=1.0 使每条请求都使用精确的目标长度。
本机数据集共有 94,145 行,其中 92,886 行可用、71,904 个不同首轮文本,
因此不存在此前“两条数据只能形成两个并发请求”的问题。
random-ids 则直接构造随机整数 token id,不读取 ShareGPT。
当前源码同时警告这种方式可能触发 NaN,因此本阶段继续使用
random + 大规模 ShareGPT,并通过清缓存隔离不同测试点。
5.2 OSL 为什么能达到指定长度
SGLang 原生请求函数位于
/sgl-workspace/sglang/python/sglang/benchmark/serving.py。
它将目标 OSL 写入 max_new_tokens,并默认设置
ignore_eos=True。因此模型即使提前生成 EOS,也会继续生成到指定 OSL;
只有请求失败、超时或触及上下文限制时,实际输出才可能不足。
sampling_params = {
"max_new_tokens": request_func_input.output_len,
"ignore_eos": not args.disable_ignore_eos,
}
5.3 为什么 Warm-up 会污染 Prefix Cache
SGLang benchmark 的 Warm-up 直接复用 input_requests[0],
而正式测量随后仍会遍历包含该请求的完整列表。因此,只要服务启用了 Prefix Cache,
第一条正式请求就可能命中刚刚 Warm-up 的前缀。第一次 Run 的服务日志实际出现
#cached-token: 768,证明该污染在当前环境真实发生。
修复方式是在每个隔离测试点传入 --flush-cache。benchmark 会先完成
Warm-up,再调用服务端 /flush_cache,最后才启动计时。这样保留 Kernel
和执行路径预热,同时不把 Warm-up 的 KV 前缀带入测量。混合干扰中的长 Prefill
注入不会清缓存,避免在 Decode 背景运行时改变其服务状态;背景与注入使用不同随机种子。
5.4 如何单独测试 Prefix Caching
- 调用
/flush_cache,发送固定长 Prompt P,记录 Cold TTFT 和#cached-token。 - 不清缓存,原样重发 P,记录 Warm TTFT;预期 cached token 明显增加、TTFT 降低。
- 再次清缓存,发送同长度但内容不同的 Prompt Q,排除长度、JIT 和偶然波动造成的假提升。
三组请求保持 OSL、采样参数和并发一致,各重复至少 3 次。Prefix Cache 是生产优化能力, 不是“坏东西”;这里只是在无缓存性能基线中隔离它,后续会把缓存命中场景作为单独 A/B。
6. 混合干扰实现
这里的“背景”不是 SGLang 后台线程,而是先启动并持续运行的一批 Decode 基准流量。它既在实验期间占用 GPU,也是我们希望观察是否 变慢的对象。混合 A/B 的问题非常具体:同样一批 Decode 请求,在没有长 Prefill 干扰和有长 Prefill 干扰时,性能会相差多少?
| 组别 | 运行内容 | 作用 |
|---|---|---|
| A:Control | 仅运行 64 条 1K → 1K, C=32 Decode | 建立无干扰基线 |
| B:Treatment | 运行相同 Decode,并在正式测量开始 10 秒后注入一条 128K → 1 Prefill | 测量 Prefill 对 Decode 的干扰 |
- 先完成 A 组,仅运行 Decode,保存对照指标。
- 启动 B 组的 Decode 基准流量,并从日志确认它已进入正式测量,而不只是完成客户端初始化。
- 正式测量开始 10 秒后,并行提交一个
128K → 1长 Prefill。 - 等待两类请求都结束,分别保存 Decode 流量和长 Prefill 请求的结果。
- 用 A、B 两组 Decode 的 Output TPS、TTFT P95、TPOT P95 与 E2E P95 计算变化率;长 Prefill 自身的 TTFT 单独报告。
A:Decode ───────────────────────────────→ 结束
B:Decode ───────────────────────────────→ 结束
正式测量 + 10 秒
└─ 128K Prefill ─→ 结束
共同占用同一服务
(
run_bench_case ... 1024 1024 32 64
) &
background_pid=$!
# 实际代码先从 bench.log 确认正式测量已经开始。
sleep 10
run_bench_case ... 131072 1 1 1
wait "${background_pid}"
& 让 Decode benchmark 与后续 Prefill 并行;
$! 取得该 Decode benchmark 的进程号;
wait 等待它完成。总请求数 64、并发 32,表示最多同时有
32 条请求在途,通常形成约两波请求。如果 Decode 流量在注入前已经结束,
两类请求没有发生重叠,结果会被明确改写为
BACKGROUND_FINISHED_BEFORE_INJECTION,避免生成虚假的“混合成功”。
7. 结果与可追溯性
results/<RUN_ID>/
run_manifest.json
run.log
summary.csv
summary.jsonl
aggregate.csv
report.md
cases/<case_id>/rep1/
bench_cmd.txt
bench.jsonl
bench.log
meta.json
server/
head_server_cmd.txt
worker_server_cmd.txt
head_server.log
worker_server.log
汇总保留 Request/Input/Output/Total TPS,以及 E2E、TTFT、TPOT、ITL 的 Mean、P50、P95、P99。断点续跑前会重新解析原始 Bench JSON,不能只凭文件存在就跳过。
8. 已完成验证
| 检查 | 结果 | 证据 |
|---|---|---|
| Shell 语法 | 通过 | bash -n run_quick_map.sh |
| Python 单测 | 3/3 通过 | 场景唯一性、百分位回退、失败结果汇总 |
| 完整 Dry-run | 通过 | 服务、九个固定点、混合 A/B、清理均展开成功 |
| 真实旧 Bench JSON 解析 | 通过 | 成功解析 P50/P95/P99 与吞吐字段 |
| 项目精简 | 通过 | 实验目录顶层仅保留一个 Shell 入口 |
| RDMA fail-closed | 静态验证通过 | 非法网卡、缺失设备或未出现 NET/IB 时禁止 benchmark |
9. 最终真机结果
正确双 Rail RDMA 下的正式结果尚未生成。本节只接受通过传输门禁、 冷缓存口径和结果校验的最终 Run;完成后将写入四点 Sanity、九个固定点、 混合 A/B 与阶段结论。
| 门禁或实验 | 状态 | 最终证据 |
|---|---|---|
双 Rail NET/IB | 待真机验证 | 头、Worker 日志均需识别 mlx5_0/mlx5_3 |
| 四点 Sanity | 待执行 | 1K/32K Prefill 与 C1/C32 Decode |
| 九个固定点 | 待执行 | 最终 summary.csv 与 report.md |
| 混合 A/B | 待执行 | Control 与 Treatment 的 Decode 指标变化 |
10. 经验教训
- 启动参数不等于实际传输路径;开始性能测试前必须由 NCCL 日志证明
NET/IB。 - Warm-up、固定随机种子和跨 Case Prefix Cache 会改变 TTFT,冷缓存与热缓存必须分开报告。
- 传输门禁或测量口径不成立时,性能结果不能用于归因模型、调度器或 Kernel。
- 完整实验前先跑少量 Sanity 点,能更早发现环境和口径问题。
历史排查细节保存在 TTFT 脚本口径审计报告 与 TP16 网络路径审计报告, 不作为本阶段最终结果。
11. 运行命令
cd /data/hzy/sskj/experiments/pro6000/dsv4pro_pro6000d_2node_sglang_tp16_quick_map
tmux new-session -d -s dsv4pro-pro6000d-2node-sglang-quick-map -c "$PWD"
tmux send-keys -t dsv4pro-pro6000d-2node-sglang-quick-map \
'RUN_ID=dsv4pro-pro6000d-2node-sglang-quick-v2-20260730-143625 bash run_quick_map.sh all' Enter
tmux attach -t dsv4pro-pro6000d-2node-sglang-quick-map
下一阶段: Phase 2:Prefill 硬件指标归因