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)
