[ https://issues.apache.org/jira/browse/SPARK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sean Owen updated SPARK-6569: ----------------------------- Priority: Trivial (was: Minor) Assignee: Platon Potapov Issue Type: Improvement (was: Bug) > Kafka directInputStream logs what appear to be incorrect warnings > ----------------------------------------------------------------- > > Key: SPARK-6569 > URL: https://issues.apache.org/jira/browse/SPARK-6569 > Project: Spark > Issue Type: Improvement > Components: Streaming > Affects Versions: 1.3.0 > Environment: Spark 1.3.0 > Reporter: Platon Potapov > Assignee: Platon Potapov > Priority: Trivial > Fix For: 1.4.0 > > > During what appears to be normal operation of streaming from a Kafka topic, > the following log records are observed, logged periodically: > {code} > [Stage 391:==========================================> (3 + 0) / > 4] > 2015-03-27 12:49:54 WARN KafkaRDD: Beginning offset ${part.fromOffset} is the > same as ending offset skipping raw 0 > 2015-03-27 12:49:54 WARN KafkaRDD: Beginning offset ${part.fromOffset} is the > same as ending offset skipping raw 0 > 2015-03-27 12:49:54 WARN KafkaRDD: Beginning offset ${part.fromOffset} is the > same as ending offset skipping raw 0 > {code} > * the part.fromOffset placeholder is not correctly substituted to a value > * is the condition really mandates a warning being logged? -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org