[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-8037:
Labels: kafka kafka-connect pull-request-available stale-assigned (was:
auto-closed
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-8037:
--
Labels: kafka kafka-connect pull-request-available stale-assigned
stale-minor (was: kafka
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-8037:
--
Labels: kafka kafka-connect pull-request-available stale-minor (was: kafka
kafka-connect
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8037:
--
Labels: kafka kafka-connect pull-request-available (was: kafka
kafka-connect)
> Missing cast
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-8037:
--
Component/s: Connectors / Kafka
> Missing cast in integer arithmetic in
>
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8037:
--
Labels: kafka kafka-connect (was: kafka-connect)
> Missing cast in integer arithmetic in
>
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8037:
--
Labels: kafka-connect (was: )
> Missing cast in integer arithmetic in
>
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8037:
--
Description:
{code}
public Set generateIdsToAbort() {
Set idsToAbort = new HashSet<>();
for (int i =
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8037:
--
Description:
{code}
public Set generateIdsToAbort() {
Set idsToAbort = new HashSet<>();
for (int i =
