Skip to content

Commit 80f7ac3

Browse files
zsxwingcloud-fan
authored andcommitted
[SPARK-21253][CORE] Disable spark.reducer.maxReqSizeShuffleToMem
## What changes were proposed in this pull request? Disable spark.reducer.maxReqSizeShuffleToMem because it breaks the old shuffle service. Credits to wangyum Closes apache#18466 ## How was this patch tested? Jenkins Author: Shixiong Zhu <[email protected]> Author: Yuming Wang <[email protected]> Closes apache#18467 from zsxwing/SPARK-21253.
1 parent 4996c53 commit 80f7ac3

File tree

2 files changed

+2
-9
lines changed

2 files changed

+2
-9
lines changed

core/src/main/scala/org/apache/spark/internal/config/package.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -323,10 +323,11 @@ package object config {
323323

324324
private[spark] val REDUCER_MAX_REQ_SIZE_SHUFFLE_TO_MEM =
325325
ConfigBuilder("spark.reducer.maxReqSizeShuffleToMem")
326+
.internal()
326327
.doc("The blocks of a shuffle request will be fetched to disk when size of the request is " +
327328
"above this threshold. This is to avoid a giant request takes too much memory.")
328329
.bytesConf(ByteUnit.BYTE)
329-
.createWithDefaultString("200m")
330+
.createWithDefault(Long.MaxValue)
330331

331332
private[spark] val TASK_METRICS_TRACK_UPDATED_BLOCK_STATUSES =
332333
ConfigBuilder("spark.taskMetrics.trackUpdatedBlockStatuses")

docs/configuration.md

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -528,14 +528,6 @@ Apart from these, the following properties are also available, and may be useful
528528
By allowing it to limit the number of fetch requests, this scenario can be mitigated.
529529
</td>
530530
</tr>
531-
<tr>
532-
<td><code>spark.reducer.maxReqSizeShuffleToMem</code></td>
533-
<td>200m</td>
534-
<td>
535-
The blocks of a shuffle request will be fetched to disk when size of the request is above
536-
this threshold. This is to avoid a giant request takes too much memory.
537-
</td>
538-
</tr>
539531
<tr>
540532
<td><code>spark.shuffle.compress</code></td>
541533
<td>true</td>

0 commit comments

Comments
 (0)