Skip to content

DDP Hang from Uneven Dataset Sizes Across Ranks

When using DistributedSampler without drop_last=True, the dataset size might not be perfectly divisible by the number of GPUs. Consequently, some ranks might have N batches, while others have N-1. The ranks that finish early exit the training loop, while the remaining ranks enter the next batch and block indefinitely on dist.all_reduce waiting for the finished ranks.

Quick answer

When using DistributedSampler without drop_last=True, the dataset size might not be perfectly divisible by the number of GPUs.

Symptom
RuntimeError: NCCL error in: ../torch/csrc/distributed/c10d/ProcessGroupNCCL.cpp
Root cause
When using DistributedSampler without drop_last=True, the dataset size might not be perfectly divisible by the number of GPUs. Consequently, some ranks might have N batches, while others have N-1. The ranks that finish early exit the training loop, while the remaining ranks enter the next batch and block indefinitely on dist.
Recommended fix
Use the Join context manager for training loops. from torch.distributed.algorithms.join import Join with Join([model]): for batch in dataloader: ... The Join context manager shadows collective communications for ranks that finish early, satisfying the all-reduce expectations of the active ranks.
How Denpex helps
Denpex matches DDP Hang from Uneven Dataset Sizes Across Ranks across every rank in a distributed run and reports which rank failed first, so you act on the initiating node instead of the loudest one.
Synchronization#NCCL Timeout

What this failure is

DDP Hang from Uneven Dataset Sizes Across Ranks is a Synchronization failure seen during ML training runs. When using DistributedSampler without drop_last=True, the dataset size might not be perfectly divisible by the number of GPUs. Consequently, some ranks might have N batches, while others have N-1. The ranks that finish early exit the training loop, while the remaining ranks enter the next batch and block indefinitely on dist.all_reduce waiting for the finished ranks. Common tags: NCCL Timeout.

Live diagnosis, no signup

Is this what broke your run? Paste your log.

You're reading about DDP Hang from Uneven Dataset Sizes Across Ranks. Paste your own crash log or traceback below and get the real root cause for YOUR run, not this generic entry. No account, no card. Logs are masked at ingress and never saved to account history.

training_logs.txt
No log to hand? Try one:

3 free diagnoses/day

Want 14 days on the Scale plan?

Request an evaluation code. A verified workplace organization activates up to 50 diagnoses a day, alerts, history, and follow-up questions. No credit card or automatic subscription.

Evaluate one incident

Why it happens (the mechanism)

The timeout happens up to 30 minutes after the actual discrepancy occurred. Engineers often mistake this for a transient network issue or hardware failure on the cluster because the logs point to NCCL.

What you'll observe

  • RuntimeError: NCCL error in: ../torch/csrc/distributed/c10d/ProcessGroupNCCL.cpp
  • nccl timeout (Watchdog detected a stall)

Common symptoms and what they mean

SymptomWhy it happens
Training hangs at the very end of an epoch.When using DistributedSampler without drop_last=True, the dataset size might not be perfectly divisible by the number of GPUs. Consequently, some ranks might have N batches, while others have N-1. The ranks that finish early exit the training loop, while the remaining ranks enter the next batch and block indefinitely on dist.all_reduce waiting for the finished ranks.
The job ultimately fails with a NCCL Watchdog Timeout after a long delay (default 30 minutes).When using DistributedSampler without drop_last=True, the dataset size might not be perfectly divisible by the number of GPUs. Consequently, some ranks might have N batches, while others have N-1. The ranks that finish early exit the training loop, while the remaining ranks enter the next batch and block indefinitely on dist.all_reduce waiting for the finished ranks.

Which systems are affected

  • PyTorch
  • NCCL
  • DistributedDataParallel (DDP)

How to confirm this is the problem

Use this checklist to test the hypothesis against a small reproduction. No single line proves the root cause, so preserve the preceding events and compare one variable at a time.

  • Check the length of the dataloader on all ranks: print(f'Rank {rank} batches: {len(dataloader)}')
  • Enable NCCL_DEBUG=INFO to see which ranks are timing out.

Searchable error signature

search key
RuntimeError: NCCL error in: ../torch/csrc/distributed/c10d/ProcessGroupNCCL.cpp

Use this text as a lookup key in logs and upstream issue trackers. It is not presented as a captured customer log. Confirm the cause from your own preceding events, versions, configuration and the cited references.

The fix and the prevention pattern

The root cause is on this page and stays free. A free account adds the exact remediation steps, saved history, and the fix on every entry in the encyclopedia.

Sign up free. Unlock the full analysis

No credit card. Daily allowance follows verified trust tier. Instant access.

Diagnose this failure in VS Code

Select the traceback or open the failed terminal, then run Denpex locally to see the initiating rank, collateral failures, exact fix, and verification command without uploading the log.

Install the free VS Code extension

NCCL errors in context

NCCL is where a distributed job reports failure, which is not the same as where it failed. The hub lists every common NCCL error next to what it actually indicates, and the environment variables that tell them apart.

Compare every nccl error side by side

Root cause

  • When using DistributedSampler without drop_last=True, the dataset size might not be perfectly divisible by the number of GPUs. Consequently, some ranks might have N batches, while others have N-1. The ranks that finish early exit the training loop, while the remaining ranks enter the next batch and block indefinitely on dist.all_reduce waiting for the finished ranks.

The fix and how to prevent it

Evaluate Denpex on your own logs

Request a Scale evaluation code. A verified workplace organization activates 14 days with up to 50 diagnoses a day. Every account keeps its current diagnosis allowance and gets a verification path. No card or automatic subscription.

We send a single-use code tied to that address. Static provider and TLD rules do not reject valid addresses. Account trust determines the benefit after signup.

Don't just read the fix, diagnose your run

The encyclopedia tells you what went wrong. Denpex tells you what went wrong in YOUR training run. With your logs, your config, and your stack.