Skip to content
Closed
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
set appid
  • Loading branch information
rxin committed Sep 5, 2015
commit 2e091149e5a3c897f89eef8585af78bcb40c820a
Original file line number Diff line number Diff line change
Expand Up @@ -186,7 +186,7 @@ class ReceivedBlockHandlerSuite
}

test("Test Block - isFullyConsumed") {
val sparkConf = new SparkConf()
val sparkConf = new SparkConf().set("spark.app.id", "streaming-test")
sparkConf.set("spark.storage.unrollMemoryThreshold", "512")
// spark.storage.unrollFraction set to 0.4 for BlockManager
sparkConf.set("spark.storage.unrollFraction", "0.4")
Expand Down