[FLINK-8037] Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort

• Type: Bug
• Status: Reopened
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Connectors / Kafka
• Labels: kafka kafka-connect pull-request-available stale-assigned
• Assignee: Greg Hogan
• Reporter: Ted Yu
• Created: 08/Nov/17 21:24
• Updated: 29/Jul/21 07:36

Description

  public Set<String> generateIdsToAbort() {
    Set<String> idsToAbort = new HashSet<>();
    for (int i = 0; i < safeScaleDownFactor; i++) {
      idsToAbort.addAll(generateIdsToUse(i * poolSize * totalNumberOfSubtasks));

The operands are integers where generateIdsToUse() expects long parameter.

Issue Links

• links to: GitHub Pull Request #5205
• links to: GitHub Pull Request #5205