diff options
author | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-09 23:03:34 -0800 |
---|---|---|
committer | Charles Reiss <charles@eecs.berkeley.edu> | 2012-12-09 23:03:34 -0800 |
commit | b53dd28c908580bf84f798eb39cf4449d6dab216 (patch) | |
tree | ffae181b9ef41b50fcec8f7a208003a572de1f90 | |
parent | 714c8d32d56c64c259931dc15f41db959f667ee0 (diff) | |
download | spark-b53dd28c908580bf84f798eb39cf4449d6dab216.tar.gz spark-b53dd28c908580bf84f798eb39cf4449d6dab216.tar.bz2 spark-b53dd28c908580bf84f798eb39cf4449d6dab216.zip |
Changed default block manager heartbeat interval to 5 s
-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 4753f7f956..bb6fc34f5d 100644 --- a/core/src/main/scala/spark/storage/BlockManager.scala +++ b/core/src/main/scala/spark/storage/BlockManager.scala @@ -932,7 +932,7 @@ object BlockManager extends Logging { } def getHeartBeatFrequencyFromSystemProperties: Long = - System.getProperty("spark.storage.blockManagerHeartBeatMs", "2000").toLong + System.getProperty("spark.storage.blockManagerHeartBeatMs", "5000").toLong def getDisableHeartBeatsForTesting: Boolean = System.getProperty("spark.test.disableBlockManagerHeartBeat", "false").toBoolean |