diff --git a/core/src/main/scala/spark/CacheTracker.scala b/core/src/main/scala/spark/CacheTracker.scala index 0de829d7bcecefb81005d4e461b9346f521d5a3b..6826c7897cae6a907ac17b88c117d2e44a336bac 100644 --- a/core/src/main/scala/spark/CacheTracker.scala +++ b/core/src/main/scala/spark/CacheTracker.scala @@ -38,7 +38,7 @@ class CacheTrackerActor extends DaemonActor with Logging { case DroppedFromCache(rddId, partition, host) => logInfo("Cache entry removed: (%s, %s) on %s".format(rddId, partition, host)) - locs(rddId)(partition) -= host + locs(rddId)(partition) = locs(rddId)(partition).filterNot(_ == host) case MemoryCacheLost(host) => logInfo("Memory cache lost on " + host) diff --git a/core/src/main/scala/spark/Stage.scala b/core/src/main/scala/spark/Stage.scala index 82b70ce60d78cfcfc081f616bae1393efc5995bc..401b33bd1629927a68c52ee5fb8ff7b5ab24dc38 100644 --- a/core/src/main/scala/spark/Stage.scala +++ b/core/src/main/scala/spark/Stage.scala @@ -22,7 +22,7 @@ class Stage(val id: Int, val rdd: RDD[_], val shuffleDep: Option[ShuffleDependen def removeOutputLoc(partition: Int, host: String) { val prevList = outputLocs(partition) - val newList = prevList - host + val newList = prevList.filterNot(_ == host) outputLocs(partition) = newList if (prevList != Nil && newList == Nil) numAvailableOutputs -= 1 diff --git a/core/src/main/scala/spark/repl/SparkCompletion.scala b/core/src/main/scala/spark/repl/SparkCompletion.scala index 9fa41736f3c281cc3c9e70ade81b587932298e1e..c6ed1860f019e54f9a2dd68831f2991f47a8c1aa 100644 --- a/core/src/main/scala/spark/repl/SparkCompletion.scala +++ b/core/src/main/scala/spark/repl/SparkCompletion.scala @@ -107,7 +107,7 @@ class SparkCompletion(val repl: SparkInterpreter) extends SparkCompletionOutput class TypeMemberCompletion(val tp: Type) extends CompletionAware with CompilerCompletion { def excludeEndsWith: List[String] = Nil def excludeStartsWith: List[String] = List("<") // <byname>, <repeated>, etc. - def excludeNames: List[String] = anyref.methodNames -- anyRefMethodsToShow ++ List("_root_") + def excludeNames: List[String] = anyref.methodNames.filterNot(anyRefMethodsToShow.contains) ++ List("_root_") def methodSignatureString(sym: Symbol) = { def asString = new MethodSymbolOutput(sym).methodString()