aboutsummaryrefslogtreecommitdiff
path: root/core/src/test
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2012-10-02 12:01:32 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2012-10-02 12:01:32 -0700
commit22684653a55d00dce448aaf1619a75879ccb5af0 (patch)
treef2a3f9e336cf72004218d8314bf8a35fd2df25ac /core/src/test
parent42e0a68082327c78dbd0fd313145124d9b8a9d98 (diff)
downloadspark-22684653a55d00dce448aaf1619a75879ccb5af0.tar.gz
spark-22684653a55d00dce448aaf1619a75879ccb5af0.tar.bz2
spark-22684653a55d00dce448aaf1619a75879ccb5af0.zip
Revert "Place Spray repo ahead of Cloudera in Maven search path"
This reverts commit 42e0a68082327c78dbd0fd313145124d9b8a9d98.
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 8f4b9d395f..d15d7285a7 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")
- // Drop a1 and a2 from memory; this should be reported back to the master
- store.dropFromMemory("a1", null)
- store.dropFromMemory("a2", null)
+ // 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))
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")