Chia-Ping Tsai created KAFKA-17452:
--------------------------------------
Summary: Fix flaky QuorumControllerTest#testUncleanShutdownBroker
Key: KAFKA-17452
URL: https://issues.apache.org/jira/browse/KAFKA-17452
Project: Kafka
Issue Type: Test
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
{code:java}
Error
org.opentest4j.AssertionFailedError: PartitionRegistration(replicas=[3, 1, 2],
directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA,
AAAAAAAAAAAAAAAAAAAAAA], isr=[3], removingReplicas=[], addingReplicas=[],
elr=[], lastKnownElr=[], leader=-1, leaderRecoveryState=RECOVERED,
leaderEpoch=3, partitionEpoch=3) ==> expected: <1> but was: <0>
Stacktrace
org.opentest4j.AssertionFailedError: PartitionRegistration(replicas=[3, 1, 2],
directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA,
AAAAAAAAAAAAAAAAAAAAAA], isr=[3], removingReplicas=[], addingReplicas=[],
elr=[], lastKnownElr=[], leader=-1, leaderRecoveryState=RECOVERED,
leaderEpoch=3, partitionEpoch=3) ==> expected: <1> but was: <0>
at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)
at
org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:197)
at
org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:150)
at org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:563)
at
org.apache.kafka.controller.QuorumControllerTest.testUncleanShutdownBroker(QuorumControllerTest.java:427)
at java.lang.reflect.Method.invoke(Method.java:498)
at java.util.ArrayList.forEach(ArrayList.java:1259)
at java.util.ArrayList.forEach(ArrayList.java:1259)
Suppressed: org.apache.kafka.server.fault.FaultHandlerException:
fatalFaultHandler: exception while renouncing leadership: Attempt to resign
from epoch 1 which is larger than the current epoch 0
at
org.apache.kafka.metalog.LocalLogManager.resign(LocalLogManager.java:752)
at
org.apache.kafka.controller.QuorumController.renounce(QuorumController.java:1268)
at
org.apache.kafka.controller.QuorumController.handleEventException(QuorumController.java:545)
at
org.apache.kafka.controller.QuorumController.access$800(QuorumController.java:180)
at
org.apache.kafka.controller.QuorumController$ControllerWriteEvent.complete(QuorumController.java:878)
at
org.apache.kafka.controller.QuorumController$ControllerWriteEvent.handleException(QuorumController.java:868)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.completeWithException(KafkaEventQueue.java:153)
at
org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:142)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:215)
at
org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:186)
at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.IllegalArgumentException: Attempt to resign from
epoch 1 which is larger than the current epoch 0
... 11 more
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
