Skip to content

Commit ed4ef15

Browse files
committed
Converted bang to ask to avoid scary warning when a block is removed.
1 parent 191279c commit ed4ef15

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/storage/BlockManagerMasterActor.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,7 @@ class BlockManagerMasterActor(val isLocal: Boolean, conf: SparkConf, listenerBus
250250
// Remove the block from the slave's BlockManager.
251251
// Doesn't actually wait for a confirmation and the message might get lost.
252252
// If message loss becomes frequent, we should add retry logic here.
253-
blockManager.get.slaveActor ! RemoveBlock(blockId)
253+
blockManager.get.slaveActor.ask(RemoveBlock(blockId))(akkaTimeout)
254254
}
255255
}
256256
}

0 commit comments

Comments
 (0)