Modern recommendation models have increased to trillions of parameters. As cluster scales expand to O(1k), distributed training bottlenecks shift from computation and memory to data movement, especially lookup and communication latency associated with embeddings. Existing solutions either optimize only one bottleneck or improve throughput by sacrificing training consistency. This paper presents NestPipe, a large-scale decentralized embedding training framework that tackles both bottlenecks while preserving synchronous training semantics. NestPipe exploits two hierarchical sparse parallelism opportunities through nested pipelining. At the inter-batch level, Dual-Buffer Pipelining (DBP) constructs a staleness-free five-stage pipeline through dual-buffer synchronization, mitigating lookup bottlenecks without embedding staleness. At the intra-batch level, we identify the embedding freezing phenomenon, which inspires Frozen-Window Pipelining (FWP) to overlap All2All communication with dense computation via coordinated stream scheduling and key-centric sample clustering. Experiments on production GPU and NPU clusters with 1,536 workers demonstrate that NestPipe achieves up to 3.06x speedup and 94.07% scaling efficiency.
Figures & tables
Fig. 1 : Hybrid decentralized architecture for large-scale recommendation training.
TABLE I : Comprehensive comparison of existing works with NestPipe.
Fig. 2 : Impact of cluster scale on sparse lookup and communication overhead.
Fig. 3 : Overview of NestPipe.
Fig. 4 : Dual-buffer synchronization in DBP strategy.
Fig. 5 : Implementation of FWP strategy through coordinated communication and computation stream scheduling.
Cluster
Dataset
Method
Step
Speedup
Ablation Study
Latency
Lookup
Comm.
Industrial
TorchRec
5793.83
1.00 ×
2870.99
1207.85
1536
2D-SP
4914.01
1.18 ×
2766.68
438.36
NPUs
UniEmb
2919.76
1.98 ×
36.21
1169.01
NestPipe
1895.98
3.06 ×
30.19
154.23
TorchRec
4207.94
1.00 ×
856.63
312.19
TABLE II : Overall latency (ms) of different methods on GPU and NPU clusters, and ablation study of DBP and FWP.
Fig. 6 : The training loss and accuracy curve of different methods.
# Worker
TorchRec
2D-SP
UniEmb
NestPipe
QPS
Speedup
Scaling
QPS
Speedup
Scaling
QPS
Speedup
Scaling
QPS
Speedup
Scaling
128
0.26
1.00 ×
-
0.27
1.04 ×
-
0.33
1.27 ×
-
0.37
1.42 ×
-
256
0.47
1.00 ×
91.23%
0.49
1.04 ×
91.36%
0.63
1.34 ×
96.13%
0.72
1.53 ×
98.39%
512
0.68
1.00 ×
66.64%
0.75
1.10 ×
69.64%
1.17
1.72 ×
89.21%
1.43
2.10 ×
97.33%
1024
1.09
1.00 ×
53.36%
1.22
1.12 ×
56.67%
2.04
1.87 ×
78.00%
2.80
2.57 ×
95.63%
1536
1.36
1.00 ×
44.34%
1.60
1.18 ×
49.32%
2.65
1.98 ×
67.62%
4.14
3.06 ×
94.07%
TABLE III : Scaling performance comparison of different methods. QPS is reported in the scale of 105 . The speedup is computed against TorchRec under the same cluster configuration. The scaling factor is normalized to the 128-worker baseline.
Fig. 7 : Step latency breakdown of different methods for varying cluster sizes.
Fig. 8 : Resource utilization ratio of different methods for varying cluster sizes.
Fig. 9 : Impact of micro-batch size on step latency and exposed comm. ratio under a constant batch size of 512.
Fig. 10 : Step latency breakdown for varying embedding dimensions, dense layers, and sequence lengths.
Method
Total Comm. Latency (ms)
Exposed Comm. Latency (ms)
QPS
Scaling
TorchRec
1207.85
1207.85
1.36
44.34%
2D-SP
438.36
438.36
1.60
49.32%
NestPipe
1185.60
154.23
4.14
94.07%
NestPipe+2D-SP
452.34
55.64
4.32
97.17%
TABLE IV : Integration of NestPipe and 2D-SP optimizations on 1,536 workers. QPS is reported in the scale of 105 , and the scaling factor is normalized to the 128-worker baseline.
Modern industrial Deep Learning Recommendation Models typically extract user preferences through the analysis of sequential interaction histories, subsequently generating predictions based on these derived interests. The inherent heterogeneity in data characteristics frequently result in substantial under-utilization of computational resources during large-scale training, primarily due to computational bubbles caused by severe stragglers and slow blocking communications. This paper introduces FreeScale, a solution designed to (1) mitigate the straggler problem through meticulously load balanced input samples (2) minimize the blocking communication by overlapping prioritized embedding communications with computations (3) resolve the GPU resource competition during computation and communication overlapping by communicating through SM-Free techniques. Empirical evaluation demonstrates that FreeScale achieves up to 90.3% reduction in computational bubbles when applied to real-world workloads running on 256 H100 GPUs.
Large-scale model training increasingly relies on composing multiple parallelism strategies, such as data, pipeline, and expert parallelism, together with memory-saving optimizations like ZeRO. Deployed systems for foundation model pretraining often rely on human experts to manually design a high-level parallelism strategy then implement the corresponding low-level execution strategy, making it difficult to adapt the system to new strategies. Meanwhile, many general-purpose frameworks are more flexible but their implementations are still tied to a fixed set of common parallelism strategies, making it challenging to integrate state-of-the-art strategies. We present Piper, a user-controllable distributed training system that decouples the strategy from the runtime implementation. Piper allows users to declare a comprehensive distributed training strategy with a small set of model annotations and scheduling directives. Each directive applies a transformation on Piper's intermediate representation (IR), a unified global training DAG that represents all computation and communication. Using this IR, Piper compiles per-device execution plans and executes them with a distributed runtime agnostic to the strategy. We show that the combined system maintains performance parity on commonly available strategies such as ZeRO, while also enabling additional performance and memory efficiency gains through joint scheduling of compute and communication in composed parallelism strategies such as DeepSeek-V3's DualPipe.
Megan Frisella, Shubham Tiwari, Andy Ruan +5
University of Washington Seattle, WA, USA · University of Washington and Shanghai Jiao Tong University Seattle, WA, USA
Lightweight proxy models enable rapid experimentation without repeatedly training frontier-scale systems, but their small kernels often leave modern accelerators underutilized. Conventional training compounds this inefficiency by scheduling the forward and backward passes as disjoint phases, so spare capacity in one cannot be filled by work from the other. We reinterpret the detachment mechanism of Forward-Forward (FF) as a scheduling primitive: given a local objective, detaching a block's output removes downstream gradient dependencies, making its backward pass ready when its forward pass finishes. ERASE launches each detached subgraph's backward pass early on a separate CUDA stream, overlapping it with subsequent forward work. Execution trace on a lightweight transformer demonstrates this overlap and its limit: a kernel that saturates the device leaves no capacity for concurrency. On a large-scale click-through-rate model, detaching six dense subarchitectures improves training throughput by up to 9.51% while keeping normalized entropy close to the baseline.