You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Efrat Levitan (Jira)" <ji...@apache.org> on 2026/03/10 08:40:00 UTC
[jira] [Created] (FLINK-39234) KafkaWriterFaultToleranceITCase flakiness due to NotLeaderOrFollowerException
Efrat Levitan created FLINK-39234:
-------------------------------------
Summary: KafkaWriterFaultToleranceITCase flakiness due to NotLeaderOrFollowerException
Key: FLINK-39234
URL: https://issues.apache.org/jira/browse/FLINK-39234
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka, Tests
Reporter: Efrat Levitan
tests in KafkaWriterFaultToleranceITCase fail due to`org.apache.kafka.common.errors.NotLeaderOrFollowerException` thrown instead of other expected exceptions:
{code:java}
2026-03-09T20:53:50.7773820Z [ERROR] org.apache.flink.connector.kafka.sink.KafkaWriterFaultToleranceITCase.testFlushExceptionWhenKafkaUnavailable Time elapsed: 6.008 s <<< FAILURE!
2026-03-09T20:53:50.7775290Z java.lang.AssertionError:
2026-03-09T20:53:50.7775562Z
2026-03-09T20:53:50.7775908Z Expecting actual throwable to be an instance of any of the following types:
2026-03-09T20:53:50.7776654Z [org.apache.kafka.common.errors.NetworkException,
2026-03-09T20:53:50.7777307Z org.apache.kafka.common.errors.TimeoutException]
2026-03-09T20:53:50.7778036Z but was:
2026-03-09T20:53:50.7779801Z org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only for the leader, this error indicates that the broker is not the current leader. For requests intended for any replica, this error indicates that the broker is not a replica of the topic partition.
2026-03-09T20:53:50.7788393Z
2026-03-09T20:53:50.7789580Z at org.apache.flink.connector.kafka.sink.KafkaWriterFaultToleranceITCase.testFlushExceptionWhenKafkaUnavailable(KafkaWriterFaultToleranceITCase.java:93)
2026-03-09T20:53:50.7792426Z at java.base/java.lang.reflect.Method.invoke(Method.java:566)
2026-03-09T20:53:50.7793169Z at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
2026-03-09T20:53:50.7793939Z at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
{code}
example failure
https://github.com/apache/flink-connector-kafka/actions/runs/22686855351/job/66358437651?pr=234
--
This message was sent by Atlassian Jira
(v8.20.10#820010)