[
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
[
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
[
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
[
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
[
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
> -
[
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
> -
[
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
[
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
