dalelane opened a new pull request, #308: URL: https://github.com/apache/flink-connector-kafka/pull/308
SourceTopicIntegrityTest.testTopicIntegritySuccess has been intermittently failing in CI workflows, reporting that it has got more records than it was expecting. The test now runs each subscription mode twice — once with the sink set to at-least-once delivery and once to exactly-once where previously it only ever ran at-least-once. In the at-least-once runs it checks that no records were lost rather than insisting on an exact count, so a harmless retry that writes a record twice no longer fails the test. In the exactly-once runs still hold the sink to an exact count because that mode promises no duplicates. -- 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]
