[Training v3.0 consolidation] DLRM optimization: evaluate Parquet reader and generation parameters to improve throughput
Nobody has claimed this yet.
- Dominant language
- Python
- Stars
- 203
- Forks
- 67
- Avg merge
- 20m
- Merged PRs (30d)
- 8
Description
Summary
This issue proposes a focused investigation into the Parquet-based data path used by the DLRM workload, with the goal of improving effective read throughput while keeping Parquet as the on-disk format.
Motivation
DLRM currently relies on Parquet files for sample storage. Preliminary observations suggest that throughput per accelerator may be limited by reader-side overhead (decoding, batching, threading) and/or by suboptimal file generation parameters (row group size, compression, page size, file count/size distribution), rather than by raw storage bandwidth.
Preserving Parquet as the format is desirable for compatibility and ecosystem alignment, so the goal is to quantify how far the current pipeline can be pushed by tuning parameters before considering format-level alternatives.
Proposed methodology
- Define a baseline DLRM dataset and a fixed accelerator/host configuration.
- Sweep one parameter at a time, then perform a small combined sweep on the most promising candidates.
- For each run, record:
- Achieved throughput (GB/s, samples/s) per accelerator
- CPU utilization (overall and per worker)
- Storage-side metrics (read IOPS, average request size)
- Reader latency distribution
- Compare against the DLRM target throughput (≥15 GB/s per accelerator; reference compute times 0.00038 s for GB200 and 0.00056 s for MI300X — see #353).
Success criteria
- A documented set of Parquet generation and reader parameters that meet or exceed the DLRM target throughput on representative storage backends.
- A short report quantifying the contribution of each parameter to overall throughput and CPU cost.
- Recommendations for default values to ship in
mlpstoragefor DLRM datagen and training.
Related
- #333 (Evaluate Arrow IPC format as an alternative reader format)
- #353 (Confirm computation time step for DLRM)
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
No files, tests, or code entry points are named. Begin by defining the baseline DLRM dataset and fixed accelerator/host configuration, then run the proposed Parquet reader and generation-parameter sweeps while recording throughput, CPU, storage, and latency metrics. Done means a documented parameter set, contribution report, and default-value recommendations for mlpstorage.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- python
- Domain
- data-engineering, machine-learning, performance
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Quiet
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100