ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[SPARK-6279][Streaming]In KafkaRDD.scala, Miss expressions flag "s" at logging string

Browse source 
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"
This commit is contained in:
zzcclp 2015-03-11 12:22:24 +00:00 committed by Sean Owen
parent 40f49795e2
commit ec30c17822
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala vendored
View file

@ -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 {