More minor changes.

Author: tdas

core/src/main/scala/org/apache/spark/storage/BlockManager.scala

@@ -793,7 +793,7 @@ private[spark] class BlockManager(
    */
   private def getPeers(forceFetch: Boolean): HashSet[BlockManagerId] = {
     val cachedPeersTtl = conf.getInt("spark.storage.cachedPeersTtl", 1000) // milliseconds
-    def timeout = System.currentTimeMillis - lastPeerFetchTime > cachedPeersTtl
+    val timeout = System.currentTimeMillis - lastPeerFetchTime > cachedPeersTtl
 
     cachedPeers.synchronized {
       if (cachedPeers.isEmpty || forceFetch || timeout) {

core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala

@@ -46,9 +46,8 @@ import org.apache.spark.scheduler.LiveListenerBus
 import org.apache.spark.serializer.{JavaSerializer, KryoSerializer}
 import org.apache.spark.shuffle.hash.HashShuffleManager
 import org.apache.spark.storage.BlockManagerMessages.BlockManagerHeartbeat
-import org.apache.spark.util.{AkkaUtils, ByteBufferInputStream, SizeEstimator, Utils}
 import org.apache.spark.storage.StorageLevel._
-import org.apache.spark.storage.BlockManagerMessages.BlockManagerHeartbeat
+import org.apache.spark.util.{AkkaUtils, ByteBufferInputStream, SizeEstimator, Utils}
 
 
 class BlockManagerSuite extends FunSuite with Matchers with BeforeAndAfter