Skip to content
Snippets Groups Projects
Commit b53dd28c authored by Charles Reiss's avatar Charles Reiss
Browse files

Changed default block manager heartbeat interval to 5 s

parent 714c8d32
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment