You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2015/05/29 07:48:43 UTC
[2/2] spark git commit: [HOTFIX] Minor style fix from last commit
[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 <pa...@databricks.com>
Authored: Thu May 28 22:48:02 2015 -0700
Committer: Patrick Wendell <pa...@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org