[HOTFIX] Minor style fix from last commit
Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e419821c Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e419821c Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e419821c Branch: refs/heads/branch-1.4 Commit: e419821c3b10e59e9765c6d41d80694772e5c772 Parents: 7a52fdf Author: Patrick Wendell <patr...@databricks.com> Authored: Thu May 28 22:48:02 2015 -0700 Committer: Patrick Wendell <patr...@databricks.com> Committed: Thu May 28 22:48:25 2015 -0700 ---------------------------------------------------------------------- .../org/apache/spark/streaming/dstream/SocketInputDStream.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/e419821c/streaming/src/main/scala/org/apache/spark/streaming/dstream/SocketInputDStream.scala ---------------------------------------------------------------------- diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/SocketInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/SocketInputDStream.scala index 96e0a9c..5ce5b7a 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/dstream/SocketInputDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/dstream/SocketInputDStream.scala @@ -78,8 +78,9 @@ class SocketReceiver[T: ClassTag]( } if (!isStopped()) { restart("Socket data stream had no more data") + } else { + logInfo("Stopped receiving") } - logInfo("Stopped receiving") } catch { case e: java.net.ConnectException => restart("Error connecting to " + host + ":" + port, e) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org