diff options
| author | Sean Owen <sowen@cloudera.com> | 2015-04-06 10:18:56 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-04-06 10:18:56 +0100 |
| commit | 9fe41252198df71f4629843d363db8c83f36440c (patch) | |
| tree | 9e933f62b05f67af70c8c6a234d01f7bace38fa8 /external | |
| parent | 49f38824a4770fc9017e6cc9b1803c4543b0c081 (diff) | |
| download | spark-9fe41252198df71f4629843d363db8c83f36440c.tar.gz spark-9fe41252198df71f4629843d363db8c83f36440c.tar.bz2 spark-9fe41252198df71f4629843d363db8c83f36440c.zip | |
SPARK-6569 [STREAMING] Down-grade same-offset message in Kafka streaming to INFO
Reduce "is the same as ending offset" message to INFO level per JIRA discussion
Author: Sean Owen <sowen@cloudera.com>
Closes #5366 from srowen/SPARK-6569 and squashes the following commits:
8a5b992 [Sean Owen] Reduce "is the same as ending offset" message to INFO level per JIRA discussion
Diffstat (limited to 'external')
| -rw-r--r-- | external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala index 4a83b715fa..a0b8a0c565 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala +++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala @@ -86,7 +86,7 @@ class KafkaRDD[ val part = thePart.asInstanceOf[KafkaRDDPartition] assert(part.fromOffset <= part.untilOffset, errBeginAfterEnd(part)) if (part.fromOffset == part.untilOffset) { - log.warn(s"Beginning offset ${part.fromOffset} is the same as ending offset " + + log.info(s"Beginning offset ${part.fromOffset} is the same as ending offset " + s"skipping ${part.topic} ${part.partition}") Iterator.empty } else { |