[ https://issues.apache.org/jira/browse/SPARK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Platon Potapov updated SPARK-6569: ---------------------------------- Description: 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 logged? was: During what appears to be normal operation of streaming from a Kafka topic, the following log records are observed, logged periodically: [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 * the "${part.fromOffset}" is not correctly substituted to a value * is the condition really mandates a warning logged? > 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: Bug > Components: Streaming > Affects Versions: 1.3.0 > Environment: Spark 1.3.0 > Reporter: Platon Potapov > Priority: Minor > > 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 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