Fix type parameter error in class NettyBlockRpcServer

biaoma-ty · biaoma-ty · commit 190d7fa8e8e2 · 2016-08-25T23:37:44.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/network/netty/NettyBlockRpcServer.scala b/core/src/main/scala/org/apache/spark/network/netty/NettyBlockRpcServer.scala
@@ -89,7 +89,7 @@ class NettyBlockRpcServer(
           BlockCache.addAll(blockIds)
         }
 
-        responseContext.onSuccess(new Array[Byte](0))
+        responseContext.onSuccess(ByteBuffer.allocate(0))
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -89,7 +89,7 @@ class NettyBlockRpcServer(`
`89`	`89`	`BlockCache.addAll(blockIds)`
`90`	`90`	`}`
`91`	`91`
`92`		`- responseContext.onSuccess(new Array[Byte](0))`
	`92`	`+ responseContext.onSuccess(ByteBuffer.allocate(0))`
`93`	`93`	`}`
`94`	`94`	`}`
`95`	`95`