[
https://issues.apache.org/jira/browse/SPARK-28489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shixiong Zhu updated SPARK-28489:
-
Affects Version/s: 2.4.0
2.4.1
2.4.2
>
[
https://issues.apache.org/jira/browse/SPARK-28489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shixiong Zhu updated SPARK-28489:
-
Description:
KafkaOffsetRangeCalculator.getRanges may drop offsets due to round off errors.
[
https://issues.apache.org/jira/browse/SPARK-28489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjoon Hyun updated SPARK-28489:
--
Labels: correctness dataloss (was: )
> KafkaOffsetRangeCalculator.getRanges may drop offsets