[jira] [Created] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

["Ted Yu (JIRA)" <ji...@apache.org>]

Ted Yu created KAFKA-6875:
-----------------------------

             Summary: EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky
                 Key: KAFKA-6875
                 URL: https://issues.apache.org/jira/browse/KAFKA-6875
             Project: Kafka
          Issue Type: Test
            Reporter: Ted Yu


From https://builds.apache.org/job/kafka-trunk-jdk10/81/testReport/junit/org.apache.kafka.streams.integration/EosIntegrationTest/shouldNotViolateEosIfOneTaskFails/ :
{code}
java.lang.AssertionError: Condition not met within timeout 60000. SteamsTasks did not request commit.
	at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276)
	at org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails(EosIntegrationTest.java:339)
{code}
From test output:
{code}
[2018-05-07 19:04:18,236] ERROR [Controller id=2 epoch=3] Controller 2 epoch 3 failed to change state for partition __transaction_state-34 from OnlinePartition to OnlinePartition (state.change.logger:76)
kafka.common.StateChangeFailedException: Failed to elect leader for partition __transaction_state-34 under strategy ControlledShutdownPartitionLeaderElectionStrategy
	at kafka.controller.PartitionStateMachine.$anonfun$doElectLeaderForPartitions$9(PartitionStateMachine.scala:328)
	at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:59)
	at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:52)
	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
	at kafka.controller.PartitionStateMachine.doElectLeaderForPartitions(PartitionStateMachine.scala:326)
	at kafka.controller.PartitionStateMachine.electLeaderForPartitions(PartitionStateMachine.scala:254)
	at kafka.controller.PartitionStateMachine.doHandleStateChanges(PartitionStateMachine.scala:175)
	at kafka.controller.PartitionStateMachine.handleStateChanges(PartitionStateMachine.scala:116)
	at kafka.controller.KafkaController$ControlledShutdown.doControlledShutdown(KafkaController.scala:1055)
	at kafka.controller.KafkaController$ControlledShutdown.$anonfun$process$1(KafkaController.scala:1031)
	at scala.util.Try$.apply(Try.scala:209)
	at kafka.controller.KafkaController$ControlledShutdown.process(KafkaController.scala:1031)
	at kafka.controller.ControllerEventManager$ControllerEventThread.$anonfun$doWork$1(ControllerEventManager.scala:69)
{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)