Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.12.0, 1.12.1, 1.12.2
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
- links to