diff options
| -rw-r--r-- | core/src/main/scala/org/apache/spark/broadcast/BroadcastManager.scala | 2 | ||||
| -rw-r--r-- | docs/configuration.md | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/broadcast/BroadcastManager.scala b/core/src/main/scala/org/apache/spark/broadcast/BroadcastManager.scala index c88be6aba6..8f8a0b11f9 100644 --- a/core/src/main/scala/org/apache/spark/broadcast/BroadcastManager.scala +++ b/core/src/main/scala/org/apache/spark/broadcast/BroadcastManager.scala @@ -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] diff --git a/docs/configuration.md b/docs/configuration.md index 9d3fe74414..a70007c165 100644 --- a/docs/configuration.md +++ b/docs/configuration.md @@ -419,7 +419,7 @@ Apart from these, the following properties are also available, and may be useful </tr> <tr> <td><code>spark.broadcast.factory</code></td> - <td>org.apache.spark.broadcast.<br />HttpBroadcastFactory</td> + <td>org.apache.spark.broadcast.<br />TorrentBroadcastFactory</td> <td> Which broadcast implementation to use. </td> |