[
https://issues.apache.org/jira/browse/SPARK-23125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaoshijie updated SPARK-23125:
---
Description:
I find DirectKafkaInputDStream(kafka010) Offset commit failed when batch time
is more
[
https://issues.apache.org/jira/browse/SPARK-23125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaoshijie updated SPARK-23125:
---
Description:
I find DirectKafkaInputDStream(kafka010) Offset commit failed when batch time
is more
[
https://issues.apache.org/jira/browse/SPARK-23125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaoshijie updated SPARK-23125:
---
Description:
I find DirectKafkaInputDStream(kafka010) Offset commit failed when batch time
is more
[
https://issues.apache.org/jira/browse/SPARK-23125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaoshijie updated SPARK-23125:
---
Description:
I find DirectKafkaInputDStream(kafka010) Offset commit failed when batch time
is more
[
https://issues.apache.org/jira/browse/SPARK-23125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaoshijie updated SPARK-23125:
---
Description:
I find DirectKafkaInputDStream(kafka010) Offset commit failed when batch time
is more
[
https://issues.apache.org/jira/browse/SPARK-23125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhaoshijie updated SPARK-23125:
---
Description: I find DirectKafkaInputDStream(kafka010) Offset commit failed
when batch time is more