[
https://issues.apache.org/jira/browse/KAFKA-8144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211335#comment-17211335
]
Bill Bejeck commented on KAFKA-8144:
------------------------------------
Since this is not a blocker, there is no active PR I'm clearing the "fix
version" field as part of the 2.7.0 release process.
> Flaky Test ControllerIntegrationTest#testMetadataPropagationOnControlPlane
> --------------------------------------------------------------------------
>
> Key: KAFKA-8144
> URL: https://issues.apache.org/jira/browse/KAFKA-8144
> Project: Kafka
> Issue Type: Bug
> Components: core, unit tests
> Affects Versions: 2.3.0
> Reporter: Matthias J. Sax
> Priority: Critical
> Labels: flaky-test
> Fix For: 2.7.0, 2.6.1
>
>
> [https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk8/detail/kafka-trunk-jdk8/3485/tests]
> {quote}java.lang.AssertionError: expected:<1.0> but was:<0.0>
> at org.junit.Assert.fail(Assert.java:89)
> at org.junit.Assert.failNotEquals(Assert.java:835)
> at org.junit.Assert.assertEquals(Assert.java:555)
> at org.junit.Assert.assertEquals(Assert.java:685)
> at
> kafka.controller.ControllerIntegrationTest.testMetadataPropagationOnControlPlane(ControllerIntegrationTest.scala:105){quote}
> STDOUT
> {quote}[2019-03-22 02:42:56,725] ERROR [ReplicaFetcher replicaId=1,
> leaderId=0, fetcherId=0] Error for partition t-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.
> [2019-03-22 02:43:00,875] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
> fetcherId=0] Error for partition test-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.
> [2019-03-22 02:43:00,876] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
> fetcherId=0] Error for partition test-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.
> [2019-03-22 02:43:25,090] ERROR [ReplicaFetcher replicaId=0, leaderId=1,
> fetcherId=0] Error for partition t-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.
> [2019-03-22 02:43:32,102] ERROR [ReplicaFetcher replicaId=0, leaderId=1,
> fetcherId=0] Error for partition t-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.
> [2019-03-22 02:43:34,073] ERROR [Controller id=0] Error completing preferred
> replica leader election for partition t-0
> (kafka.controller.KafkaController:76)
> kafka.common.StateChangeFailedException: Failed to elect leader for partition
> t-0 under strategy PreferredReplicaPartitionLeaderElectionStrategy
> at
> kafka.controller.PartitionStateMachine.$anonfun$doElectLeaderForPartitions$9(PartitionStateMachine.scala:390)
> at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62)
> at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49)
> at
> kafka.controller.PartitionStateMachine.doElectLeaderForPartitions(PartitionStateMachine.scala:388)
> at
> kafka.controller.PartitionStateMachine.electLeaderForPartitions(PartitionStateMachine.scala:315)
> at
> kafka.controller.PartitionStateMachine.doHandleStateChanges(PartitionStateMachine.scala:225)
> at
> kafka.controller.PartitionStateMachine.handleStateChanges(PartitionStateMachine.scala:141)
> at
> kafka.controller.KafkaController.kafka$controller$KafkaController$$onPreferredReplicaElection(KafkaController.scala:649)
> at
> kafka.controller.KafkaController$PreferredReplicaLeaderElection.handleProcess(KafkaController.scala:1597)
> at
> kafka.controller.PreemptableControllerEvent.process(KafkaController.scala:1809)
> at
> kafka.controller.PreemptableControllerEvent.process$(KafkaController.scala:1807)
> at
> kafka.controller.KafkaController$PreferredReplicaLeaderElection.process(KafkaController.scala:1551)
> at
> kafka.controller.ControllerEventManager$ControllerEventThread.$anonfun$doWork$1(ControllerEventManager.scala:95)
> at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
> at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:31)
> at
> kafka.controller.ControllerEventManager$ControllerEventThread.doWork(ControllerEventManager.scala:95)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:89)
> [2019-03-22 02:43:41,232] ERROR [ReplicaFetcher replicaId=0, leaderId=1,
> fetcherId=0] Error for partition t-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.
> [2019-03-22 02:43:53,465] ERROR [ReplicaStateMachine controllerId=0]
> Controller moved to another broker when moving some replicas to
> OfflineReplica state (kafka.controller.ReplicaStateMachine:76)
> org.apache.kafka.common.errors.ControllerMovedException: Controller epoch
> zkVersion check fails. Expected zkVersion = 1
> [2019-03-22 02:43:53,467] INFO [ControllerEventThread controllerId=0]
> Controller moved to another broker when processing TopicDeletion.
> (kafka.controller.ControllerEventManager$ControllerEventThread:68)
> org.apache.kafka.common.errors.ControllerMovedException: Controller epoch
> zkVersion check fails. Expected zkVersion = 1
> [2019-03-22 02:44:11,463] WARN Unable to read additional data from client
> sessionid 0x1047745e3da0000, likely client has closed socket
> (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-22 02:44:11,750] INFO [ControllerEventThread controllerId=0]
> Controller moved to another broker when processing PartitionReassignment.
> (kafka.controller.ControllerEventManager$ControllerEventThread:68)
> org.apache.kafka.common.errors.ControllerMovedException: Controller epoch
> zkVersion check fails. Expected zkVersion = 1
> [2019-03-22 02:44:13,674] ERROR [PartitionStateMachine controllerId=0]
> Controller moved to another broker when trying to create the topic partition
> state znode (kafka.controller.PartitionStateMachine:76)
> org.apache.kafka.common.errors.ControllerMovedException: Controller epoch
> zkVersion check fails. Expected zkVersion = 1
> [2019-03-22 02:44:13,675] ERROR [PartitionStateMachine controllerId=0]
> Controller moved to another broker when moving some partitions to
> OnlinePartition state (kafka.controller.PartitionStateMachine:76)
> org.apache.kafka.common.errors.ControllerMovedException: Controller epoch
> zkVersion check fails. Expected zkVersion = 1
> [2019-03-22 02:44:13,675] INFO [ControllerEventThread controllerId=0]
> Controller moved to another broker when processing TopicChange.
> (kafka.controller.ControllerEventManager$ControllerEventThread:68)
> org.apache.kafka.common.errors.ControllerMovedException: Controller epoch
> zkVersion check fails. Expected zkVersion = 1
> [2019-03-22 02:44:19,629] WARN Unable to read additional data from client
> sessionid 0x10477460b560000, likely client has closed socket
> (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-22 02:44:20,729] WARN Unable to read additional data from client
> sessionid 0x104774613810002, likely client has closed socket
> (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-22 02:44:27,067] INFO [ControllerEventThread controllerId=0]
> Controller moved to another broker when processing
> PreferredReplicaLeaderElection(None,kafka.controller.KafkaController$ZkTriggered$@30073b5f,kafka.controller.KafkaController$PreferredReplicaLeaderElection$$$Lambda$613/891418305@4c8b5b7d).
> (kafka.controller.ControllerEventManager$ControllerEventThread:68)
> org.apache.kafka.common.errors.ControllerMovedException: Controller epoch
> zkVersion check fails. Expected zkVersion = 1
> [2019-03-22 02:44:29,971] ERROR [ReplicaFetcher replicaId=0, leaderId=1,
> fetcherId=0] Error for partition t-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.
> [2019-03-22 02:44:34,135] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
> fetcherId=0] Error for partition topic1-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.
> [2019-03-22 02:44:34,140] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
> fetcherId=0] Error for partition topic1-1 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition.{quote}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
