ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Random is the default choice; rarestFirst didn't work well in

Browse source 
experiments.
This commit is contained in:
Mosharaf Chowdhury 2011-03-29 13:06:43 -07:00
parent 0416cc22d2
commit 73b165220d
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
core/src/main/scala/spark/BitTorrentBroadcast.scala
View file

@ -444,7 +444,7 @@ extends Broadcast[T] with Logging {
threadPool.getActiveCount
while (hasBlocks < totalBlocks && numThreadsToCreate > 0) {
var peerToTalkTo = pickPeerToTalkToRarestFirst
var peerToTalkTo = pickPeerToTalkToRandom
if (peerToTalkTo != null)
logInfo ("Peer chosen: " + peerToTalkTo + " with " + peerToTalkTo.hasBlocksBitVector)