aboutsummaryrefslogtreecommitdiff
path: root/core/src
diff options
context:
space:
mode:
authorMark Hamstra <markhamstra@gmail.com>2014-01-07 16:39:37 -0800
committerMark Hamstra <markhamstra@gmail.com>2014-01-07 16:39:37 -0800
commit86ed1ad2520662f4a16e535cc05bf2296e6053df (patch)
tree8fde5d73ba8a11fcd67ccf56ed05499565183fd4 /core/src
parent7d5fa175ca9cd2260c7bcd18c201bc087d4f62c3 (diff)
downloadspark-86ed1ad2520662f4a16e535cc05bf2296e6053df.tar.gz
spark-86ed1ad2520662f4a16e535cc05bf2296e6053df.tar.bz2
spark-86ed1ad2520662f4a16e535cc05bf2296e6053df.zip
Fix BlockManagerSuite#after
Diffstat (limited to 'core/src')
-rw-r--r--core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala10
1 files changed, 2 insertions, 8 deletions
diff --git a/core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala b/core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala
index a0fc3445be..fded582640 100644
--- a/core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala
@@ -40,8 +40,6 @@ class BlockManagerSuite extends FunSuite with BeforeAndAfter with PrivateMethodT
var actorSystem: ActorSystem = null
var master: BlockManagerMaster = null
var oldArch: String = null
- var oldOops: String = null
- var oldHeartBeat: String = null
// Reuse a serializer across tests to avoid creating a new thread-local buffer on each test
conf.set("spark.kryoserializer.buffer.mb", "1")
@@ -61,7 +59,7 @@ class BlockManagerSuite extends FunSuite with BeforeAndAfter with PrivateMethodT
Left(actorSystem.actorOf(Props(new BlockManagerMasterActor(true, conf)))), conf)
// Set the arch to 64-bit and compressedOops to true to get a deterministic test-case
- System.setProperty("os.arch", "amd64")
+ oldArch = System.setProperty("os.arch", "amd64")
conf.set("os.arch", "amd64")
conf.set("spark.test.useCompressedOops", "true")
conf.set("spark.storage.disableBlockManagerHeartBeat", "true")
@@ -94,11 +92,7 @@ class BlockManagerSuite extends FunSuite with BeforeAndAfter with PrivateMethodT
System.clearProperty("os.arch")
}
- if (oldOops != null) {
- conf.set("spark.test.useCompressedOops", oldOops)
- } else {
- System.clearProperty("spark.test.useCompressedOops")
- }
+ System.clearProperty("spark.test.useCompressedOops")
}
test("StorageLevel object caching") {