You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/05/22 23:58:00 UTC
[jira] [Resolved] (KAFKA-6875)
EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky
[ https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ted Yu resolved KAFKA-6875.
---------------------------
Resolution: Cannot Reproduce
> 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)