Skip to content

Commit

Permalink
Use TorrentBroadcastFactory.
Browse files Browse the repository at this point in the history
  • Loading branch information
rxin committed Jul 30, 2014
1 parent 991c002 commit cf38450
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ private[spark] class BroadcastManager(
synchronized {
if (!initialized) {
val broadcastFactoryClass =
conf.get("spark.broadcast.factory", "org.apache.spark.broadcast.HttpBroadcastFactory")
conf.get("spark.broadcast.factory", "org.apache.spark.broadcast.TorrentBroadcastFactory")

broadcastFactory =
Class.forName(broadcastFactoryClass).newInstance.asInstanceOf[BroadcastFactory]
Expand Down

0 comments on commit cf38450

Please sign in to comment.