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

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

              Dates

                Created:
                Updated:
                Resolved: