[FLINK-21933] [kinesis][efo] EFO consumer treats interrupts as retryable exceptions

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0, 1.12.1, 1.12.2
• Fix Version/s: 1.13.0, 1.12.3
• Component/s: Connectors / Kinesis
• Labels: pull-request-available
• Assignee: Danny Cranmer
• Reporter: Danny Cranmer
• Created: 23/Mar/21 15:20
• Updated: 25/Mar/21 13:53
• Resolved: 25/Mar/21 13:53

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.

Issue Links

• links to: GitHub Pull Request #15347