diff options
author | Liang-Chi Hsieh <viirya@gmail.com> | 2015-02-04 00:52:41 -0800 |
---|---|---|
committer | Tathagata Das <tdas@databricks.com> | 2015-02-04 00:52:41 -0800 |
commit | a74cbbf12fa59df37eb7172652138c78707d33d8 (patch) | |
tree | 1fde3aa046ddd2f7e322583095c7a27b5d59197c /streaming/src | |
parent | 4cf4cba08f1757ec0d9bffdfae6db719a4fb5a3f (diff) | |
download | spark-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/src')
-rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala | 2 |
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") } |