Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21933

[kinesis][efo] EFO consumer treats interrupts as retryable exceptions

    XMLWordPrintableJSON

    Details

      Description

      Background
      When an Flink job is cancelled or failed, the source threads get interrupted. The EFO consumer is treating this exception as retryable and will retry until MAX_RETRIES is exceeded.

      Scope
      Update error handling to treat Interrupted exceptions as non-recoverable. The source should gracefully shutdown.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dannycranmer Danny Cranmer
                Reporter:
                dannycranmer Danny Cranmer
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: