aboutsummaryrefslogtreecommitdiff
path: root/streaming
diff options
context:
space:
mode:
authorLiang-Chi Hsieh <viirya@gmail.com>2015-02-04 00:52:41 -0800
committerTathagata Das <tdas@databricks.com>2015-02-04 00:52:41 -0800
commita74cbbf12fa59df37eb7172652138c78707d33d8 (patch)
tree1fde3aa046ddd2f7e322583095c7a27b5d59197c /streaming
parent4cf4cba08f1757ec0d9bffdfae6db719a4fb5a3f (diff)
downloadspark-a74cbbf12fa59df37eb7172652138c78707d33d8.tar.gz
spark-a74cbbf12fa59df37eb7172652138c78707d33d8.tar.bz2
spark-a74cbbf12fa59df37eb7172652138c78707d33d8.zip
[Minor] Fix incorrect warning log
The warning log looks incorrect. Just fix it. Author: Liang-Chi Hsieh <viirya@gmail.com> Closes #4360 from viirya/fixing_typo and squashes the following commits: 48fbe4f [Liang-Chi Hsieh] Fix incorrect warning log.
Diffstat (limited to 'streaming')
-rw-r--r--streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala
index 00456ab2a0..b36aeb341d 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala
@@ -254,7 +254,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
// Check if all the receivers have been deregistered or not
if (!receiverInfo.isEmpty) {
- logWarning("All of the receivers have not deregistered, " + receiverInfo)
+ logWarning("Not all of the receivers have deregistered, " + receiverInfo)
} else {
logInfo("All of the receivers have deregistered successfully")
}