We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f15806a commit 8a5b992Copy full SHA for 8a5b992
external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
@@ -86,7 +86,7 @@ class KafkaRDD[
86
val part = thePart.asInstanceOf[KafkaRDDPartition]
87
assert(part.fromOffset <= part.untilOffset, errBeginAfterEnd(part))
88
if (part.fromOffset == part.untilOffset) {
89
- 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 " +
90
s"skipping ${part.topic} ${part.partition}")
91
Iterator.empty
92
} else {
0 commit comments