[SPARK-3709] Executors don't always report broadcast block removal pr…

…operly back to the driver (for branch-1.1) Author: Reynold Xin <[email protected]> Closes #2591 from rxin/SPARK-3709-1.1 and squashes the following commits: ab99cc0 [Reynold Xin] [SPARK-3709] Executors don't always report broadcast block removal properly back to the driver (cherry picked from commit a8c6e82) Signed-off-by: Reynold Xin <[email protected]>
apache · Sep 30, 2014 · b539b0e · b539b0e
1 parent 4f991c9
commit b539b0e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveActor.scala b/core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveActor.scala
@@ -57,9 +57,9 @@ class BlockManagerSlaveActor(
         blockManager.shuffleBlockManager.removeShuffle(shuffleId)
       }
 
-    case RemoveBroadcast(broadcastId, tellMaster) =>
+    case RemoveBroadcast(broadcastId, _) =>
       doAsync[Int]("removing broadcast " + broadcastId, sender) {
-        blockManager.removeBroadcast(broadcastId, tellMaster)
+        blockManager.removeBroadcast(broadcastId, tellMaster = true)
       }
 
     case GetBlockStatus(blockId, _) =>