You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Chia-Ping Tsai (Jira)" <ji...@apache.org> on 2024/08/30 16:30:00 UTC
[jira] [Created] (KAFKA-17452) Fix flaky QuorumControllerTest#testUncleanShutdownBroker
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)