diff options
| author | Patrick Wendell <patrick@databricks.com> | 2015-05-28 22:48:02 -0700 |
|---|---|---|
| committer | Patrick Wendell <patrick@databricks.com> | 2015-05-28 22:48:02 -0700 |
| commit | 36067ce398e2949c2f122625e67fd5497febdee6 (patch) | |
| tree | 693271d664c16de385f95fb1c7cd01482f24adbc /streaming | |
| parent | e714ecf277a7412ea8263662977fe3ad1f794975 (diff) | |
| download | spark-36067ce398e2949c2f122625e67fd5497febdee6.tar.gz spark-36067ce398e2949c2f122625e67fd5497febdee6.tar.bz2 spark-36067ce398e2949c2f122625e67fd5497febdee6.zip | |
[HOTFIX] Minor style fix from last commit
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/dstream/SocketInputDStream.scala | 3 |
1 files changed, 2 insertions, 1 deletions
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 96e0a9c1a8..5ce5b7aae6 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) |