Code style fix.

ho3rexqj · ho3rexqj · commit a6e5e810402d · 2018-01-11T22:15:15.000-05:00
diff --git a/core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala b/core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala
@@ -208,7 +208,7 @@ private[spark] class TorrentBroadcast[T: ClassTag](obj: T, id: Long)
     TorrentBroadcast.synchronized {
       val broadcastCache = SparkEnv.get.broadcastManager.cachedValues
 
-      Option(broadcastCache.get(broadcastId)).map(_.asInstanceOf[T]).getOrElse({
+      Option(broadcastCache.get(broadcastId)).map(_.asInstanceOf[T]).getOrElse {
         setConf(SparkEnv.get.conf)
         val blockManager = SparkEnv.get.blockManager
         blockManager.getLocalValues(broadcastId) match {
@@ -250,7 +250,7 @@ private[spark] class TorrentBroadcast[T: ClassTag](obj: T, id: Long)
               blocks.foreach(_.dispose())
             }
         }
-      })
+      }
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -208,7 +208,7 @@ private[spark] class TorrentBroadcast[T: ClassTag](obj: T, id: Long)`
`208`	`208`	`TorrentBroadcast.synchronized {`
`209`	`209`	`val broadcastCache = SparkEnv.get.broadcastManager.cachedValues`
`210`	`210`
`211`		`- Option(broadcastCache.get(broadcastId)).map(_.asInstanceOf[T]).getOrElse({`
	`211`	`+ Option(broadcastCache.get(broadcastId)).map(_.asInstanceOf[T]).getOrElse {`
`212`	`212`	`setConf(SparkEnv.get.conf)`
`213`	`213`	`val blockManager = SparkEnv.get.blockManager`
`214`	`214`	`blockManager.getLocalValues(broadcastId) match {`
`@@ -250,7 +250,7 @@ private[spark] class TorrentBroadcast[T: ClassTag](obj: T, id: Long)`
`250`	`250`	`blocks.foreach(_.dispose())`
`251`	`251`	`}`
`252`	`252`	`}`
`253`		`- })`
	`253`	`+ }`
`254`	`254`	`}`
`255`	`255`	`}`
`256`	`256`