diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-07-09 13:19:36 -0700 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2015-07-09 13:19:36 -0700 |
| commit | 7ce3b818fb1ba3f291eda58988e4808e999cae3a (patch) | |
| tree | 795ad151334df1aabd2a851e12d8474e45ecb909 | |
| parent | 0b0b9ceaf73de472198c9804fb7ae61fa2a2e097 (diff) | |
| download | spark-7ce3b818fb1ba3f291eda58988e4808e999cae3a.tar.gz spark-7ce3b818fb1ba3f291eda58988e4808e999cae3a.tar.bz2 spark-7ce3b818fb1ba3f291eda58988e4808e999cae3a.zip | |
[MINOR] [STREAMING] Fix log statements in ReceiverSupervisorImpl
Log statements incorrectly showed that the executor was being stopped when receiver was being stopped.
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #7328 from tdas/fix-log and squashes the following commits:
9cc6e99 [Tathagata Das] Fix log statements.
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala b/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala index 33be067ebd..eeb14ca3a4 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala @@ -182,12 +182,12 @@ private[streaming] abstract class ReceiverSupervisor( /** Wait the thread until the supervisor is stopped */ def awaitTermination() { + logInfo("Waiting for receiver to be stopped") stopLatch.await() - logInfo("Waiting for executor stop is over") if (stoppingError != null) { - logError("Stopped executor with error: " + stoppingError) + logError("Stopped receiver with error: " + stoppingError) } else { - logWarning("Stopped executor without error") + logInfo("Stopped receiver without error") } if (stoppingError != null) { throw stoppingError |