fixed comment

apache · Oct 12, 2014 · 81d69f0 · 81d69f0
1 parent efd93f2
commit 81d69f0
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManagerMasterActor.scala b/core/src/main/scala/org/apache/spark/storage/BlockManagerMasterActor.scala
@@ -236,8 +236,7 @@ class BlockManagerMasterActor(val isLocal: Boolean, conf: SparkConf) extends Act
     if (!blockManagerInfo.contains(id)) {
       blockManagerIdByExecutor.get(id.executorId) match {
         case Some(manager) =>
-          // A block manager of the same executor already exists.
-          // This should never happen. Let's just quit.
+          // A block manager of the same executor already exists so remove it (assumed dead).
           logError("Got two different block manager registrations on same executor - will remove, new Id " + id+", orig id - "+manager)
           removeExecutor(id.executorId)
         case None =>