slachiewicz commented on PR #310: URL: https://github.com/apache/flink-connector-kafka/pull/310#issuecomment-5617004430
The red here is [FLINK-40622](https://issues.apache.org/jira/browse/FLINK-40622), not this change: [`SourceTopicIntegrityTest.testTopicIntegrityFailure[1]`](https://github.com/apache/flink-connector-kafka/actions/runs/34455212027/job/102799893439) times out on JDK 17 with the same message as on `main`. JDK 11 and 21 were cancelled by matrix fail-fast, so it is one failure rather than three. Worth flagging for review: `FlinkKafkaInternalProducerITCase` did not run in this build at all. `SourceTopicIntegrityTest` matches `**/*Test.*` and so fails in the `default-test` execution, which ends the module before the `integration-test` phase this ITCase runs in. CI has therefore not exercised the change in either direction. Local run against a broker: `FlinkKafkaInternalProducerITCase#testResetInnerTransactionIfFinalizingTransactionFailed` gives 2 tests, 0 failures, both parameterizations. *This comment was created with AI assistance.* -- 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]
