From 107a5ca879aab6331b03c9080f0c0a782f060589 Mon Sep 17 00:00:00 2001
From: root <root@ip-10-29-232-35.ec2.internal>
Date: Sun, 23 Sep 2012 06:06:12 +0000
Subject: [PATCH] Make default number of parallel fetches slightly smaller
since it doesn't seem to hurt performance much and it will cause slightly
less GC.
---
core/src/main/scala/spark/storage/BlockManager.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 = {
--
GitLab