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)