mlcommons / mlcommons/storage

[Training v3.0 consolidation] DLRM optimization: evaluate Parquet reader and generation parameters to improve throughput

Open
#354 5 comments 0 reactions 0 assignees View on GitHub

Nobody has claimed this yet.

enhancement Future PASS Score Blocker Training
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

  1. Define a baseline DLRM dataset and a fixed accelerator/host configuration.
  2. Sweep one parameter at a time, then perform a small combined sweep on the most promising candidates.
  3. 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
  4. 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 mlpstorage for DLRM datagen and training.

Related

  • #333 (Evaluate Arrow IPC format as an alternative reader format)
  • #353 (Confirm computation time step for DLRM)

Contributor guide

Open the contributing guide

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.