You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2014/09/04 19:28:27 UTC
git commit: [Minor]Remove extra semicolon in FlumeStreamSuite.scala
Repository: spark
Updated Branches:
refs/heads/master 00362dac9 -> 905861906
[Minor]Remove extra semicolon in FlumeStreamSuite.scala
Author: GuoQiang Li <wi...@qq.com>
Closes #2265 from witgo/FlumeStreamSuite and squashes the following commits:
6c99e6e [GuoQiang Li] Remove extra semicolon in FlumeStreamSuite.scala
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/90586190
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/90586190
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/90586190
Branch: refs/heads/master
Commit: 905861906e250a0d6e6c91d9b8fd1aaa366781d3
Parents: 00362da
Author: GuoQiang Li <wi...@qq.com>
Authored: Thu Sep 4 10:28:23 2014 -0700
Committer: Reynold Xin <rx...@apache.org>
Committed: Thu Sep 4 10:28:23 2014 -0700
----------------------------------------------------------------------
.../apache/spark/streaming/flume/FlumeStreamSuite.scala | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/90586190/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala
----------------------------------------------------------------------
diff --git a/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala b/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala
index 73dffef..6ee7ac9 100644
--- a/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala
+++ b/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala
@@ -109,11 +109,11 @@ class FlumeStreamSuite extends TestSuiteBase {
}
class CompressionChannelFactory(compressionLevel: Int) extends NioClientSocketChannelFactory {
- override def newChannel(pipeline:ChannelPipeline) : SocketChannel = {
- var encoder : ZlibEncoder = new ZlibEncoder(compressionLevel);
- pipeline.addFirst("deflater", encoder);
- pipeline.addFirst("inflater", new ZlibDecoder());
- super.newChannel(pipeline);
+ override def newChannel(pipeline: ChannelPipeline): SocketChannel = {
+ val encoder = new ZlibEncoder(compressionLevel)
+ pipeline.addFirst("deflater", encoder)
+ pipeline.addFirst("inflater", new ZlibDecoder())
+ super.newChannel(pipeline)
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org