Aleksandr Pilipenko created FLINK-34407:
-------------------------------------------
Summary: Flaky tests causing workflow timeout
Key: FLINK-34407
URL: https://issues.apache.org/jira/browse/FLINK-34407
Project: Flink
Issue Type: Bug
Components: Connectors / Kinesis
Affects Versions: aws-connector-4.2.0, aws-connector-3.0.0
Reporter: Aleksandr Pilipenko
Example build:
[https://github.com/apache/flink-connector-aws/actions/runs/7735404733]
Tests are stuck retrying due to the following exception:
{code:java}
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]
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
