[
https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031949#comment-17031949
]
Matthias J. Sax edited comment on KAFKA-8940 at 2/6/20 9:28 PM:
----------------------------------------------------------------
[https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4530/testReport/junit/org.apache.kafka.streams.integration/SmokeTestDriverIntegrationTest/shouldWorkWithRebalance/]
{code:java}
[2020-02-06 19:14:34,633] ERROR [Controller id=2 epoch=2] Controller 2 epoch 2
failed to change state for partition SmokeTest-win-sum-changelog-0 from
OnlinePartition to OnlinePartition (state.change.logger:76)
kafka.common.StateChangeFailedException: Failed to elect leader for partition
SmokeTest-win-sum-changelog-0 under strategy
ControlledShutdownPartitionLeaderElectionStrategy at
kafka.controller.ZkPartitionStateMachine.$anonfun$doElectLeaderForPartitions$7(PartitionStateMachine.scala:427)
at scala.collection.IterableOnceOps.foreach(IterableOnce.scala:553) at
scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:551) at
scala.collection.AbstractIterable.foreach(Iterable.scala:921) at
kafka.controller.ZkPartitionStateMachine.doElectLeaderForPartitions(PartitionStateMachine.scala:424)
at
kafka.controller.ZkPartitionStateMachine.electLeaderForPartitions(PartitionStateMachine.scala:335)
at
kafka.controller.ZkPartitionStateMachine.doHandleStateChanges(PartitionStateMachine.scala:236)
at
kafka.controller.ZkPartitionStateMachine.handleStateChanges(PartitionStateMachine.scala:157)
at
kafka.controller.KafkaController.doControlledShutdown(KafkaController.scala:1141)
at
kafka.controller.KafkaController.$anonfun$processControlledShutdown$1(KafkaController.scala:1103)
at
kafka.controller.KafkaController.processControlledShutdown(KafkaController.scala:1103)
at kafka.controller.KafkaController.process(KafkaController.scala:1826) at
kafka.controller.QueuedEvent.process(ControllerEventManager.scala:52) at
kafka.controller.ControllerEventManager$ControllerEventThread.process$1(ControllerEventManager.scala:128)
at
kafka.controller.ControllerEventManager$ControllerEventThread.$anonfun$doWork$1(ControllerEventManager.scala:131)
at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) at
kafka.metrics.KafkaTimer.time(KafkaTimer.scala:31) at
kafka.controller.ControllerEventManager$ControllerEventThread.doWork(ControllerEventManager.scala:131)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)
{code}
was (Author: mjsax):
[https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4530/testReport/junit/org.apache.kafka.streams.integration/SmokeTestDriverIntegrationTest/shouldWorkWithRebalance/]
> Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance
> -----------------------------------------------------------------
>
> Key: KAFKA-8940
> URL: https://issues.apache.org/jira/browse/KAFKA-8940
> Project: Kafka
> Issue Type: Bug
> Components: streams, unit tests
> Reporter: Guozhang Wang
> Assignee: Guozhang Wang
> Priority: Major
> Labels: flaky-test
> Fix For: 2.5.0
>
>
> I lost the screen shot unfortunately... it reports the set of expected
> records does not match the received records.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
