Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
aws-connector-4.2.0
-
None
Description
Example build: https://github.com/apache/flink-connector-aws/actions/runs/7735404733
Tests are stuck retrying due to the following exception:
797445 [main] WARN org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout.FanOutRecordPublisher [] - Encountered recoverable error TimeoutException. Backing off for 0 millis 000000 (arn)
org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout.FanOutShardSubscriber$RecoverableFanOutSubscriberException: java.util.concurrent.TimeoutException: Timed out acquiring subscription - 000000 (arn)
at org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout.FanOutShardSubscriber.handleErrorAndRethrow(FanOutShardSubscriber.java:327) ~[classes/:?]
at org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout.FanOutShardSubscriber.openSubscriptionToShard(FanOutShardSubscriber.java:283) ~[classes/:?]
at org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout.FanOutShardSubscriber.subscribeToShardAndConsumeRecords(FanOutShardSubscriber.java:210) ~[classes/:?]
at org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout.FanOutRecordPublisher.runWithBackoff(FanOutRecordPublisher.java:177) ~[classes/:?]
at org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout.FanOutRecordPublisher.run(FanOutRecordPublisher.java:130) ~[classes/:?]
at org.apache.flink.streaming.connectors.kinesis.internals.publisher.fanout.FanOutRecordPublisherTest.testCancelExitsGracefully(FanOutRecordPublisherTest.java:595) ~[test-classes/:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_402]
Attachments
Issue Links
- links to