Skip to content

Commit

Permalink
Add context around maxBytesInFlight in our doc
Browse files Browse the repository at this point in the history
  • Loading branch information
abellina committed Sep 29, 2023
1 parent 01eaaae commit 751c756
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions docs/additional-functionality/rapids-shuffle.md
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,13 @@ configuration can be independently changed for writers and readers using:
`spark.rapids.shuffle.multiThreaded.[writer|reader].threads`. An appropriate value for these
pools is the number of cores in the system divided by the number of executors per machine.

On the reader side, when blocks are received from the network, they are queued onto these threads
for decompression and decode. The amount of bytes we allow in flight per Spark task is
controlled by: `spark.rapids.shuffle.multiThreaded.maxBytesInFlight`, and it is set to
128MB-per-task as a default. Note that this memory comes from the Netty off-heap pool, and this
is sized at startup automatically by Netty, but this limit can be controlled by setting
`-Dio.netty.maxDirectMemory=[amount in Bytes]` under `spark.executor.extraJavaOptions`.

## UCX Mode

---
Expand Down

0 comments on commit 751c756

Please sign in to comment.