[ 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 in integer arithmetic in > TransactionalIdsGenerator#generateIdsToAbort > ---------------------------------------------------------------------------------- > > Key: FLINK-8037 > URL: https://issues.apache.org/jira/browse/FLINK-8037 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Reporter: Ted Yu > Assignee: Greg Hogan > Priority: Minor > Labels: kafka, kafka-connect, pull-request-available > > {code} > public Set<String> generateIdsToAbort() { > Set<String> idsToAbort = new HashSet<>(); > for (int i = 0; i < safeScaleDownFactor; i++) { > idsToAbort.addAll(generateIdsToUse(i * poolSize * > totalNumberOfSubtasks)); > {code} > The operands are integers where generateIdsToUse() expects long parameter. -- This message was sent by Atlassian Jira (v8.3.4#803005)