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: Forgot equals.

---
 .../src/main/scala/spark/streaming/dstream/SocketInputDStream.scala     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'streaming')

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
-- 
cgit v1.2.3