From 0984647aaefffcecf85ebfbdb45e41ecd1e49a8c Mon Sep 17 00:00:00 2001 From: Patrick Wendell Date: Mon, 13 Jan 2014 23:25:25 -0800 Subject: Enable compression by default for spills --- core/src/main/scala/org/apache/spark/storage/BlockManager.scala | 2 +- docs/configuration.md | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala index 6461deee32..ed53558566 100644 --- a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala +++ b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala @@ -81,7 +81,7 @@ private[spark] class BlockManager( // Whether to compress RDD partitions that are stored serialized val compressRdds = conf.getBoolean("spark.rdd.compress", false) // Whether to compress shuffle output temporarily spilled to disk - val compressShuffleSpill = conf.getBoolean("spark.shuffle.spill.compress", false) + val compressShuffleSpill = conf.getBoolean("spark.shuffle.spill.compress", true) val heartBeatFrequency = BlockManager.getHeartBeatFrequency(conf) diff --git a/docs/configuration.md b/docs/configuration.md index be06bd19be..da70cabba2 100644 --- a/docs/configuration.md +++ b/docs/configuration.md @@ -156,7 +156,7 @@ Apart from these, the following properties are also available, and may be useful spark.shuffle.spill.compress - false + true Whether to compress data spilled during shuffles. -- cgit v1.2.3