[
https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466426#comment-16466426
]
Ted Yu commented on KAFKA-6875:
-------------------------------
>From Jenkins:
Failed 1 times in the last 10 runs. Flakiness: 11%, Stability: 90%
> EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky
> -------------------------------------------------------------
>
> Key: KAFKA-6875
> URL: https://issues.apache.org/jira/browse/KAFKA-6875
> Project: Kafka
> Issue Type: Test
> Components: streams, unit tests
> Reporter: Ted Yu
> Priority: Minor
> Labels: newbie++
> Attachments: EosIntegrationTest.out
>
>
> 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)
