HI, I was tracing the flow of replicate method in BlockManager.scala. I am trying to find out as to where exactly in the code, the resources are aquired for rdd replication.
I find that the BlockManagerMaster.getPeers() method returns only one BlockManagerId for all the rdd partitions. But, the storage details of the rdd in WebUI depicts that all the partitions are replicated over multiple nodes. I just want to find out where do we get the resources allocated for rdd replication. Can someone please help me out in this regard!! Thank you Karthik
