Skip to content

Commit

Permalink
Fixed error in unit test.
Browse files Browse the repository at this point in the history
  • Loading branch information
tdas committed Nov 10, 2014
1 parent de4ff73 commit 2ed927f
Showing 1 changed file with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ class BlockManagerReplicationSuite extends FunSuite with Matchers with BeforeAnd
master = null
}


test("get peers with addition and removal of block managers") {
val numStores = 4
val stores = (1 to numStores - 1).map { i => makeBlockManager(1000, s"store$i") }
Expand Down Expand Up @@ -150,15 +150,15 @@ class BlockManagerReplicationSuite extends FunSuite with Matchers with BeforeAnd
test("block replication - mixed between 1x to 5x") {
// Generate storage levels with varying replication
val storageLevels = Seq(
//MEMORY_ONLY,
MEMORY_ONLY,
MEMORY_ONLY_SER_2,
StorageLevel(true, false, false, false, 3),
StorageLevel(true, true, false, true, 4),
StorageLevel(true, true, false, false, 5),
StorageLevel(true, true, false, true, 4),
StorageLevel(true, false, false, false, 3),
MEMORY_ONLY_SER_2,
StorageLevel(true, false, false, false, 3)
//StorageLevel(true, true, false, true, 4),
//StorageLevel(true, true, false, false, 5),
//StorageLevel(true, true, false, true, 4),
//StorageLevel(true, false, false, false, 3),
//MEMORY_ONLY_SER_2,
//MEMORY_ONLY
MEMORY_ONLY
)
testReplication(5, storageLevels)
}
Expand Down

0 comments on commit 2ed927f

Please sign in to comment.