From 56dcad593641ef8de211fcb4303574a9f4509f89 Mon Sep 17 00:00:00 2001 From: Matei Zaharia Date: Fri, 28 Sep 2012 23:40:56 -0700 Subject: [PATCH] Don't create a Cache in SparkEnv because we don't use it --- core/src/main/scala/spark/SparkEnv.scala | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/core/src/main/scala/spark/SparkEnv.scala b/core/src/main/scala/spark/SparkEnv.scala index 280c00b486..f2a52ab356 100644 --- a/core/src/main/scala/spark/SparkEnv.scala +++ b/core/src/main/scala/spark/SparkEnv.scala @@ -19,7 +19,6 @@ import spark.util.AkkaUtils */ class SparkEnv ( val actorSystem: ActorSystem, - val cache: Cache, val serializer: Serializer, val closureSerializer: Serializer, val cacheTracker: CacheTracker, @@ -33,7 +32,7 @@ class SparkEnv ( /** No-parameter constructor for unit tests. */ def this() = { - this(null, null, new JavaSerializer, new JavaSerializer, null, null, null, null, null, null, null) + this(null, new JavaSerializer, new JavaSerializer, null, null, null, null, null, null, null) } def stop() { @@ -100,8 +99,6 @@ object SparkEnv { val closureSerializer = instantiateClass[Serializer]( "spark.closure.serializer", "spark.JavaSerializer") - val cache = instantiateClass[Cache]("spark.cache.class", "spark.BoundedMemoryCache") - val cacheTracker = new CacheTracker(actorSystem, isMaster, blockManager) blockManager.cacheTracker = cacheTracker @@ -116,7 +113,6 @@ object SparkEnv { new SparkEnv( actorSystem, - cache, serializer, closureSerializer, cacheTracker,