Minor update.

Author: rxin

core/src/main/scala/org/apache/spark/network/netty/FileClientHandler.scala

@@ -44,7 +44,7 @@ abstract class FileClientHandler extends SimpleChannelInboundHandler[ByteBuf] {
       handle(ctx, in, currentHeader)
       handlerCalled = true
       currentHeader = null
-      ctx.close
+      ctx.close()
     }
   }
 }

core/src/main/scala/org/apache/spark/network/netty/FileHeader.scala

@@ -26,7 +26,7 @@ private[spark] class FileHeader (
   val fileLen: Int,
   val blockId: BlockId) extends Logging {
 
-  lazy val buffer = {
+  lazy val buffer: ByteBuf = {
     val buf = Unpooled.buffer()
     buf.capacity(FileHeader.HEADER_SIZE)
     buf.writeInt(fileLen)

core/src/main/scala/org/apache/spark/network/netty/FileServer.scala

@@ -20,7 +20,7 @@ package org.apache.spark.network.netty
 import java.net.InetSocketAddress
 
 import io.netty.bootstrap.ServerBootstrap
-import io.netty.channel.{ChannelOption, EventLoopGroup}
+import io.netty.channel.{ChannelFuture, ChannelOption, EventLoopGroup}
 import io.netty.channel.oio.OioEventLoopGroup
 import io.netty.channel.socket.oio.OioServerSocketChannel
 
@@ -35,7 +35,7 @@ class FileServer(pResolver: PathResolver, private var port: Int) extends Logging
   private var bossGroup: EventLoopGroup = new OioEventLoopGroup
   private var workerGroup: EventLoopGroup = new OioEventLoopGroup
 
-  private var channelFuture = {
+  private var channelFuture: ChannelFuture = {
     val bootstrap = new ServerBootstrap
     bootstrap.group(bossGroup, workerGroup)
       .channel(classOf[OioServerSocketChannel])

core/src/main/scala/org/apache/spark/network/netty/FileServerHandler.scala

@@ -66,4 +66,3 @@ class FileServerHandler(pResolver: PathResolver)
     ctx.close()
   }
 }
-