diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-12 00:05:35 -0500 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-03-12 00:05:35 -0500 |
| commit | 0cf320485d60d96a6ae5f3ec6dc13aadecdef0eb (patch) | |
| tree | e76de1c489891e09459826f94fd96d337e065912 /streaming | |
| parent | 9e68f4862556995ff4a02251eac3583542c11ad8 (diff) | |
| download | spark-0cf320485d60d96a6ae5f3ec6dc13aadecdef0eb.tar.gz spark-0cf320485d60d96a6ae5f3ec6dc13aadecdef0eb.tar.bz2 spark-0cf320485d60d96a6ae5f3ec6dc13aadecdef0eb.zip | |
Forgot equals.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/SocketInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/SocketInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/SocketInputDStream.scala index 38239b054a..1408af0afa 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/SocketInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/SocketInputDStream.scala @@ -61,7 +61,7 @@ object SocketReceiver { def bytesToLines(inputStream: InputStream): Iterator[String] = { val dataInputStream = new BufferedReader(new InputStreamReader(inputStream, "UTF-8")) new NextIterator[String] { - protected override def getNext() { + protected override def getNext() = { val nextValue = dataInputStream.readLine() if (nextValue == null) { finished = true |