From 0cf320485d60d96a6ae5f3ec6dc13aadecdef0eb Mon Sep 17 00:00:00 2001
From: Stephen Haberman <stephen@exigencecorp.com>
Date: Tue, 12 Mar 2013 00:05:35 -0500
Subject: [PATCH] Forgot equals.
---
.../main/scala/spark/streaming/dstream/SocketInputDStream.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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
--
GitLab