The GitHub Actions job "Flink Connector Kafka CI" on flink-connector-kafka.git/backport-887d5941-v4.0 has failed. Run started by GitHub user MartijnVisser (triggered by MartijnVisser).
Head commit for run: 8f8f821a127094ced2e7329a73fc8afc74e8d415 / Aleksandr Savonin <[email protected]> [FLINK-39699][tests] Stabilize KafkaWriterFaultToleranceITCase exception-on-unavailable tests testFlush/testWrite/testCloseExceptionWhenKafkaUnavailable all rely on the producer still having undelivered work when KAFKA_CONTAINER.stop() takes effect. Under CI load the sender thread can ship and ack the buffered record before stop() returns, so the operation under test (flush/write/close) has nothing to fail on and the .rootCause() assertion fires with "Expecting actual not to be null" instead of seeing the expected NetworkException / TimeoutException. Drain a warm-up record before stopping the broker, then issue the real write while the broker is down. The producer's metadata is already cached so write() returns immediately; the sender fails to deliver (retries=0); the operation under test reliably surfaces the underlying exception. (cherry picked from commit 887d5941d5b6dee2044b55cac629f040336f7435) Generated-by: Claude Code (Opus 4.8) Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/26752949605 With regards, GitHub Actions via GitBox
