Repository: spark Updated Branches: refs/heads/master e714ecf27 -> 36067ce39
[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/36067ce3 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/36067ce3 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/36067ce3 Branch: refs/heads/master Commit: 36067ce398e2949c2f122625e67fd5497febdee6 Parents: e714ecf 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:02 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/36067ce3/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