Skip to content

Commit

Permalink
Minor changes.
Browse files Browse the repository at this point in the history
  • Loading branch information
tdas committed Sep 12, 2014
1 parent 03de02d commit 7598f91
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 1 deletion.
2 changes: 1 addition & 1 deletion core/src/test/resources/log4j.properties
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
#

# Set everything to be logged to the file core/target/unit-tests.log
log4j.rootCategory=DEBUG, file
log4j.rootCategory=INFO, file
log4j.appender.file=org.apache.log4j.FileAppender
log4j.appender.file.append=false
log4j.appender.file.file=target/unit-tests.log
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -91,8 +91,12 @@ class BlockManagerSuite extends FunSuite with Matchers with BeforeAndAfter
conf.set("spark.driver.port", boundPort.toString)
conf.set("spark.storage.unrollFraction", "0.4")
conf.set("spark.storage.unrollMemoryThreshold", "512")

// for block replication test, to make a replication attempt to inactive store fail fast
conf.set("spark.core.connection.ack.wait.timeout", "1")
// for block replication test, to make cached peers refresh frequently
conf.set("spark.storage.cachedPeersTtl", "10")

master = new BlockManagerMaster(
actorSystem.actorOf(Props(new BlockManagerMasterActor(true, conf, new LiveListenerBus))),
conf, true)
Expand Down

0 comments on commit 7598f91

Please sign in to comment.