z3d1k opened a new pull request, #128: URL: https://github.com/apache/flink-connector-aws/pull/128
## Purpose of the change Tests that use `FakeKinesisFanOutBehavioursFactory` occasionally run into issue while creating mock for Kinesis shard subscription: ``` java.lang.ClassCastException: org.mockito.codegen.Subscription$MockitoMock$1959866534 cannot be cast to org.reactivestreams.Subscription ``` This failure leads to `TimeoutException` in `FanOutShardSubscriber`, resulting in workflow timing out due to continuous retries. Using fake subscription implementation instead of Mockito mock to resolve this issue. ## Verifying this change This change is already covered by existing tests and can be verified by running project build in Github Actions. ## Significant changes - [ ] Dependencies have been added or upgraded - [ ] Public API has been changed (Public API is any class annotated with `@Public(Evolving)`) - [ ] Serializers have been changed - [ ] New feature has been introduced -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
