You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2015/04/06 11:19:02 UTC
spark git commit: SPARK-6569 [STREAMING] Down-grade same-offset
message in Kafka streaming to INFO
Repository: spark
Updated Branches:
refs/heads/master 49f38824a -> 9fe412521
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 <so...@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
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/9fe41252
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/9fe41252
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/9fe41252
Branch: refs/heads/master
Commit: 9fe41252198df71f4629843d363db8c83f36440c
Parents: 49f3882
Author: Sean Owen <so...@cloudera.com>
Authored: Mon Apr 6 10:18:56 2015 +0100
Committer: Sean Owen <so...@cloudera.com>
Committed: Mon Apr 6 10:18:56 2015 +0100
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/9fe41252/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala
----------------------------------------------------------------------
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 4a83b71..a0b8a0c 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 {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org