diff --git a/src/scala/spark/BitTorrentBroadcast.scala b/src/scala/spark/BitTorrentBroadcast.scala index 6a041b1ab0160e8e608c82e93708d2eea57b432c..7dc376a3c5d3a9dc06433943ed5fd3fb5cf6f2ec 100644 --- a/src/scala/spark/BitTorrentBroadcast.scala +++ b/src/scala/spark/BitTorrentBroadcast.scala @@ -10,7 +10,7 @@ import java.util.concurrent.{Executors, ThreadFactory, ThreadPoolExecutor} import scala.collection.mutable.{ListBuffer, Map, Set} @serializable -class BitTorrentBroadcast[T] (@transient var value_ : T, local: Boolean) +class BitTorrentBroadcast[T] (@transient var value_ : T, isLocal: Boolean) extends Broadcast with Logging { def value = value_ @@ -51,7 +51,7 @@ extends Broadcast with Logging { @transient var stopBroadcast = false // Must call this after all the variables have been created/initialized - if (!local) { + if (!isLocal) { sendBroadcast }