[jira] [Updated] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-09-01 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-19976: --- Description: I am using following code. While data on kafka topic get deleted/retention period is over, it t

[jira] [Updated] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-03-20 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-19976: --- Description: I am using following code. While data on kafka topic get deleted/retention period is over, it t

[jira] [Updated] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-03-16 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-19976: --- Description: I am using following code def functionToCreateContext(sc:SparkContext):StreamingContext = { val

[jira] [Updated] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-03-16 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-19976: --- Description: I am using following code def functionToCreateContext(sc:SparkContext):StreamingContext = { val

[jira] [Updated] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-03-16 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-19976: --- Priority: Critical (was: Major) > DirectStream API throws OffsetOutOfRange Exception > -

[jira] [Updated] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-03-16 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-19976: --- Priority: Major (was: Critical) > DirectStream API throws OffsetOutOfRange Exception > -

[jira] [Updated] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-03-16 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-19976: --- Description: I am using following code def functionToCreateContext(sc:SparkContext):StreamingContext = { val

[jira] [Updated] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-03-16 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-19976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-19976: --- Affects Version/s: (was: 1.6.2) 2.0.0 > DirectStream API throws OffsetOutOfRange E

[jira] [Created] (SPARK-19976) DirectStream API throws OffsetOutOfRange Exception

2017-03-16 Thread Taukir (JIRA)
Taukir created SPARK-19976: -- Summary: DirectStream API throws OffsetOutOfRange Exception Key: SPARK-19976 URL: https://issues.apache.org/jira/browse/SPARK-19976 Project: Spark Issue Type: Bug

[jira] [Updated] (SPARK-17787) spark submit throws error while using kafka Appender log4j:ERROR Could not instantiate class [kafka.producer.KafkaLog4jAppender]. java.lang.ClassNotFoundException: kafka

2016-10-05 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-17787: --- Description: While trying to push spark app logs to kafka , I am trying to use KafkaAppender. Please find th

[jira] [Updated] (SPARK-17787) spark submit throws error while using kafka Appender log4j:ERROR Could not instantiate class [kafka.producer.KafkaLog4jAppender]. java.lang.ClassNotFoundException: kafka

2016-10-05 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-17787: --- Description: While trying to push spark app logs to kafka , I am trying to use KafkaAppender. Please find th

[jira] [Updated] (SPARK-17787) spark submit throws error while using kafka Appender log4j:ERROR Could not instantiate class [kafka.producer.KafkaLog4jAppender]. java.lang.ClassNotFoundException: kafka

2016-10-05 Thread Taukir (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-17787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Taukir updated SPARK-17787: --- Priority: Major (was: Critical) > spark submit throws error while using kafka Appender log4j:ERROR Could not

[jira] [Created] (SPARK-17787) spark submit throws error while using kafka Appender log4j:ERROR Could not instantiate class [kafka.producer.KafkaLog4jAppender]. java.lang.ClassNotFoundException: kafka

2016-10-05 Thread Taukir (JIRA)
Taukir created SPARK-17787: -- Summary: spark submit throws error while using kafka Appender log4j:ERROR Could not instantiate class [kafka.producer.KafkaLog4jAppender]. java.lang.ClassNotFoundException: kafka.producer.KafkaLog4jAppender