aboutsummaryrefslogtreecommitdiff
path: root/core/src/test
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2012-10-02 11:37:19 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2012-10-02 11:37:19 -0700
commit42e0a68082327c78dbd0fd313145124d9b8a9d98 (patch)
tree3fcf6909e95a40657a4165c278c32137c648b627 /core/src/test
parentdde273f43aa0060c54568378ab394e234d7f15b6 (diff)
downloadspark-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.scala6
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")