Skip to content

Commit 1fcd5dc

Browse files
srowentdas
authored andcommitted
SPARK-1478.2 Fix incorrect NioServerSocketChannelFactory constructor call
The line break inadvertently means this was interpreted as a call to the no-arg constructor. This doesn't exist in older Netty even. (Also fixed a val name typo.) Author: Sean Owen <[email protected]> Closes #1466 from srowen/SPARK-1478.2 and squashes the following commits: 59c3501 [Sean Owen] Line break caused Scala to interpret NioServerSocketChannelFactory constructor as the no-arg version, which is not even present in some versions of Netty
1 parent d988d34 commit 1fcd5dc

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeInputDStream.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -153,15 +153,15 @@ class FlumeReceiver(
153153

154154
private def initServer() = {
155155
if (enableDecompression) {
156-
val channelFactory = new NioServerSocketChannelFactory
157-
(Executors.newCachedThreadPool(), Executors.newCachedThreadPool());
158-
val channelPipelieFactory = new CompressionChannelPipelineFactory()
156+
val channelFactory = new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),
157+
Executors.newCachedThreadPool())
158+
val channelPipelineFactory = new CompressionChannelPipelineFactory()
159159

160160
new NettyServer(
161161
responder,
162162
new InetSocketAddress(host, port),
163-
channelFactory,
164-
channelPipelieFactory,
163+
channelFactory,
164+
channelPipelineFactory,
165165
null)
166166
} else {
167167
new NettyServer(responder, new InetSocketAddress(host, port))

0 commit comments

Comments
 (0)