Efrat19 opened a new pull request, #237: URL: https://github.com/apache/flink-connector-kafka/pull/237
KafkaWriterFaultToleranceITCase#testFlushExceptionWhenKafkaUnavailable is flaky in CI due to org.apache.kafka.common.errors.NotLeaderOrFollowerException thrown instead of other expected exceptions (NetworkException / TimeoutException). This is because the topic isn't fully initialized, (see https://github.com/apache/flink-connector-kafka/pull/228) and the failure due to the missing topic races actual failures in the closing KAFKA_CONTAINER -- 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]
