diff options
| author | zzcclp <xm_zzc@sina.com> | 2015-03-11 12:22:24 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-03-11 12:22:24 +0000 |
| commit | ec30c17822329e6d2b8c85625b31ba8bd8679fcf (patch) | |
| tree | 604e6eabf87275dc5ea9a559bbb39f18d9908822 /external | |
| parent | 40f49795e2624326dd4e38eedbf63d35860ea00e (diff) | |
| download | spark-ec30c17822329e6d2b8c85625b31ba8bd8679fcf.tar.gz spark-ec30c17822329e6d2b8c85625b31ba8bd8679fcf.tar.bz2 spark-ec30c17822329e6d2b8c85625b31ba8bd8679fcf.zip | |
[SPARK-6279][Streaming]In KafkaRDD.scala, Miss expressions flag "s" at logging string
In KafkaRDD.scala, Miss expressions flag "s" at logging string
In logging file, it print `Beginning offset $
{part.fromOffset}
is the same as ending offset ` but not `Beginning offset 111 is the same as ending offset `.
Author: zzcclp <xm_zzc@sina.com>
Closes #4979 from zzcclp/SPARK-6279 and squashes the following commits:
768f88e [zzcclp] Miss expressions flag "s"
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 d56cc01be9..6d465bcb6b 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("Beginning offset ${part.fromOffset} is the same as ending offset " + + log.warn(s"Beginning offset ${part.fromOffset} is the same as ending offset " + s"skipping ${part.topic} ${part.partition}") Iterator.empty } else { |