You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2014/09/30 21:25:05 UTC
git commit: [SPARK-3709] Executors don't always report broadcast
block removal properly back to the driver (for branch-1.1)
Repository: spark
Updated Branches:
refs/heads/branch-1.1 48be6576c -> a8c6e82de
[SPARK-3709] Executors don't always report broadcast block removal properly back to the driver (for branch-1.1)
Author: Reynold Xin <rx...@apache.org>
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
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/a8c6e82d
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/a8c6e82d
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/a8c6e82d
Branch: refs/heads/branch-1.1
Commit: a8c6e82de31cb09b7e7e37caf4e52c9e10185b63
Parents: 48be657
Author: Reynold Xin <rx...@apache.org>
Authored: Tue Sep 30 12:24:58 2014 -0700
Committer: Reynold Xin <rx...@apache.org>
Committed: Tue Sep 30 12:24:58 2014 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/storage/BlockManagerSlaveActor.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/a8c6e82d/core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveActor.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveActor.scala b/core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveActor.scala
index c194e0f..4e7412a 100644
--- a/core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveActor.scala
+++ b/core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveActor.scala
@@ -58,9 +58,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, _) =>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org