[FLINK-29476] Kinesis Connector retry mechanism not applied to EOFException

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.2
• Fix Version/s: 1.16.0, 1.17.0, 1.15.3
• Component/s: Connectors / Kinesis
• Labels: pull-request-available
• Assignee: Alexander Fedulov
• Reporter: Alexander Fedulov
• Created: 29/Sep/22 14:38
• Updated: 20/Oct/22 02:32
• Resolved: 06/Oct/22 07:43

Description

The current retry mechanism in Kinesis connector only considers SocketTimeoutException as recoverable: KinesisProxy.java#L422 , however we observed that communication can also fail with EOFException: kinesis-exception.log

This exception should also be considered recoverable and retried.

Issue Links

• links to: GitHub Pull Request #20927