diff options
| author | root <root@ip-10-29-232-35.ec2.internal> | 2012-09-23 06:06:12 +0000 |
|---|---|---|
| committer | root <root@ip-10-29-232-35.ec2.internal> | 2012-09-23 06:06:12 +0000 |
| commit | 107a5ca879aab6331b03c9080f0c0a782f060589 (patch) | |
| tree | 5401d1cdea305a021a2143fcc8781e2e7e9ecdbf | |
| parent | e41cab04cafdb610f108a03a9e062d422f2eedd8 (diff) | |
| download | spark-107a5ca879aab6331b03c9080f0c0a782f060589.tar.gz spark-107a5ca879aab6331b03c9080f0c0a782f060589.tar.bz2 spark-107a5ca879aab6331b03c9080f0c0a782f060589.zip | |
Make default number of parallel fetches slightly smaller since it doesn't seem to hurt performance much and it will cause slightly less GC.
| -rw-r--r-- | core/src/main/scala/spark/storage/BlockManager.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/storage/BlockManager.scala b/core/src/main/scala/spark/storage/BlockManager.scala index 550c937ac4..15748b70d5 100644 --- a/core/src/main/scala/spark/storage/BlockManager.scala +++ b/core/src/main/scala/spark/storage/BlockManager.scala @@ -631,7 +631,7 @@ class BlockManager(val master: BlockManagerMaster, val serializer: Serializer, m object BlockManager { def getNumParallelFetchesFromSystemProperties(): Int = { - System.getProperty("spark.blockManager.parallelFetches", "8").toInt + System.getProperty("spark.blockManager.parallelFetches", "4").toInt } def getMaxMemoryFromSystemProperties(): Long = { |