Savonitar opened a new pull request, #229: URL: https://github.com/apache/flink-connector-kafka/pull/229
`RetryRule` was originally used with JUnit 4's `@Rule` to retry flaky tests in subclasses that had `@Test` methods. While there is a JUnit 5 equivalent (`RetryExtension`) which exists and works, it would have no effect here: the only classes extending `KafkaTestBase` are utility/abstract classes without test methods (`KafkaSourceTestEnv`, `DynamicKafkaSourceTestHelper`, `KafkaTestBaseWithFlink`). Test classes like `KafkaSourceITCase` and `FlinkKafkaInternalProducerITCase` use these utilities via static method calls, not inheritance, so the retry annotation does not apply to them. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
