aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala6
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