Sorry, I should send to the new dev spark address instead.
Hi,
I have one question on removeRdd method in BlockManagerMasterActor.scala
about asking slave actor to remove RDD.
in this piece of code,
Future.sequence(blockManagerInfo.values.map { bm =>
bm.slaveActor.ask(remove
Hi,
I have one question on removeRdd method in BlockManagerMasterActor.scala
about asking slave actor to remove RDD.
in this piece of code,
Future.sequence(blockManagerInfo.values.map { bm =>
bm.slaveActor.ask(removeMsg)(akkaTimeout).mapTo[Int]
}.toSeq)
it asks
