Skip to content

Commit 9fe4125

Browse files
committed
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 <[email protected]> Closes apache#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
1 parent 49f3882 commit 9fe4125

File tree

1 file changed

+1
-1
lines changed
  • external/kafka/src/main/scala/org/apache/spark/streaming/kafka

1 file changed

+1
-1
lines changed

external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ class KafkaRDD[
8686
val part = thePart.asInstanceOf[KafkaRDDPartition]
8787
assert(part.fromOffset <= part.untilOffset, errBeginAfterEnd(part))
8888
if (part.fromOffset == part.untilOffset) {
89-
log.warn(s"Beginning offset ${part.fromOffset} is the same as ending offset " +
89+
log.info(s"Beginning offset ${part.fromOffset} is the same as ending offset " +
9090
s"skipping ${part.topic} ${part.partition}")
9191
Iterator.empty
9292
} else {

0 commit comments

Comments
 (0)