diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-10-02 11:37:19 -0700 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-10-02 11:37:19 -0700 |
commit | 42e0a68082327c78dbd0fd313145124d9b8a9d98 (patch) | |
tree | 3fcf6909e95a40657a4165c278c32137c648b627 /core/src/test | |
parent | dde273f43aa0060c54568378ab394e234d7f15b6 (diff) | |
download | spark-42e0a68082327c78dbd0fd313145124d9b8a9d98.tar.gz spark-42e0a68082327c78dbd0fd313145124d9b8a9d98.tar.bz2 spark-42e0a68082327c78dbd0fd313145124d9b8a9d98.zip |
Place Spray repo ahead of Cloudera in Maven search path
Diffstat (limited to 'core/src/test')
-rw-r--r-- | core/src/test/scala/spark/storage/BlockManagerSuite.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/test/scala/spark/storage/BlockManagerSuite.scala b/core/src/test/scala/spark/storage/BlockManagerSuite.scala index d15d7285a7..8f4b9d395f 100644 --- a/core/src/test/scala/spark/storage/BlockManagerSuite.scala +++ b/core/src/test/scala/spark/storage/BlockManagerSuite.scala @@ -69,9 +69,9 @@ class BlockManagerSuite extends FunSuite with BeforeAndAfter with PrivateMethodT assert(master.mustGetLocations(GetLocations("a2")).size > 0, "master was not told about a2") assert(master.mustGetLocations(GetLocations("a3")).size === 0, "master was told about a3") - // Setting storage level of a1 and a2 to invalid; they should be removed from store and master - store.setLevelAndTellMaster("a1", new StorageLevel(false, false, false, 1)) - store.setLevelAndTellMaster("a2", new StorageLevel(true, false, false, 0)) + // Drop a1 and a2 from memory; this should be reported back to the master + store.dropFromMemory("a1", null) + store.dropFromMemory("a2", null) assert(store.getSingle("a1") === None, "a1 not removed from store") assert(store.getSingle("a2") === None, "a2 not removed from store") assert(master.mustGetLocations(GetLocations("a1")).size === 0, "master did not remove a1") |