Github user brad-kaiser commented on a diff in the pull request:
https://github.com/apache/spark/pull/19041#discussion_r142478432
--- Diff:
core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala
---
@@ -120,6 +124,10 @@ class BlockManagerMasterEndpoint(
removeExecutor(execId)
context.reply(true)
+ case ReplicateOneBlock(execId, blockId, exclude) =>
+ logDebug(s"Replicating first block on $execId")
+ context.reply(replicateOneBlock(execId, blockId, exclude))
--- End diff --
Fixed.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
