Xavier Léauté created KAFKA-5264:
------------------------------------
Summary: kafka.api.SslProducerSendTest.testSendToPartition
transient failure
Key: KAFKA-5264
URL: https://issues.apache.org/jira/browse/KAFKA-5264
Project: Kafka
Issue Type: Sub-task
Reporter: Xavier Léauté
Error Message
{code}
org.apache.kafka.common.errors.TopicExistsException: Topic 'topic' already
exists.
{code}
Stacktrace
{code}
org.apache.kafka.common.errors.TopicExistsException: Topic 'topic' already
exists.
{code}
Standard Output
{code}
[2017-05-17 17:24:31,041] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:32,898] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:32,907] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:34,792] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:34,798] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:36,665] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:36,673] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:38,657] ERROR [Controller 1]: Error while electing or
becoming controller on broker 1 (kafka.controller.KafkaController:105)
org.I0Itec.zkclient.exception.ZkInterruptedException:
java.lang.InterruptedException
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:1003)
at org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:1100)
at org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:1095)
at kafka.utils.ZkUtils.readDataMaybeNull(ZkUtils.scala:659)
at
kafka.utils.ReplicationUtils$.getLeaderIsrAndEpochForPartition(ReplicationUtils.scala:75)
at
kafka.utils.ZkUtils$$anonfun$getPartitionLeaderAndIsrForTopics$1.apply(ZkUtils.scala:708)
at
kafka.utils.ZkUtils$$anonfun$getPartitionLeaderAndIsrForTopics$1.apply(ZkUtils.scala:707)
at
scala.collection.mutable.HashMap$$anon$1$$anonfun$foreach$2.apply(HashMap.scala:134)
at
scala.collection.mutable.HashMap$$anon$1$$anonfun$foreach$2.apply(HashMap.scala:134)
at
scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:236)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
at scala.collection.mutable.HashMap$$anon$1.foreach(HashMap.scala:134)
at
kafka.utils.ZkUtils.getPartitionLeaderAndIsrForTopics(ZkUtils.scala:707)
at
kafka.controller.KafkaController.updateLeaderAndIsrCache(KafkaController.scala:736)
at
kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:664)
at
kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:255)
at kafka.controller.KafkaController.elect(KafkaController.scala:1565)
at
kafka.controller.KafkaController$Reelect$.process(KafkaController.scala:1512)
at
kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1154)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
Caused by: java.lang.InterruptedException
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:503)
at org.apache.zookeeper.ClientCnxn.submitRequest(ClientCnxn.java:1406)
at org.apache.zookeeper.ZooKeeper.getData(ZooKeeper.java:1210)
at org.apache.zookeeper.ZooKeeper.getData(ZooKeeper.java:1241)
at org.I0Itec.zkclient.ZkConnection.readData(ZkConnection.java:125)
at org.I0Itec.zkclient.ZkClient$12.call(ZkClient.java:1104)
at org.I0Itec.zkclient.ZkClient$12.call(ZkClient.java:1100)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:991)
... 19 more
[2017-05-17 17:24:38,660] ERROR [controller-event-thread]: Error processing
event Reelect (kafka.controller.KafkaController$ControllerEventThread:105)
org.I0Itec.zkclient.exception.ZkInterruptedException:
java.lang.InterruptedException
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:1003)
at org.I0Itec.zkclient.ZkClient.delete(ZkClient.java:1048)
at org.I0Itec.zkclient.ZkClient.delete(ZkClient.java:1043)
at kafka.utils.ZkUtils.deletePath(ZkUtils.scala:618)
at
kafka.controller.KafkaController.kafka$controller$KafkaController$$triggerControllerMove(KafkaController.scala:1539)
at kafka.controller.KafkaController.elect(KafkaController.scala:1578)
at
kafka.controller.KafkaController$Reelect$.process(KafkaController.scala:1512)
at
kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1154)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
Caused by: java.lang.InterruptedException
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:503)
at org.apache.zookeeper.ClientCnxn.submitRequest(ClientCnxn.java:1406)
at org.apache.zookeeper.ZooKeeper.delete(ZooKeeper.java:871)
at org.I0Itec.zkclient.ZkConnection.delete(ZkConnection.java:110)
at org.I0Itec.zkclient.ZkClient$11.call(ZkClient.java:1052)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:991)
... 8 more
[2017-05-17 17:24:38,665] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:38,674] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:40,603] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:40,610] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:42,542] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:42,548] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:54,445] ERROR Haven't been able to send leader and isr
requests, current state of the map is Map(1 -> Map(topic-1 ->
(LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:1,ControllerEpoch:2),ReplicationFactor:2),AllReplicas:0,1))).
Exception message: java.lang.InterruptedException
(kafka.controller.ControllerBrokerRequestBatch:99)
[2017-05-17 17:24:54,446] ERROR Haven't been able to send metadata update
requests to brokers Set(1), current state of the partition info is Map(topic-1
->
(LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:1,ControllerEpoch:2),ReplicationFactor:2),AllReplicas:0,1)).
Exception message: java.lang.InterruptedException
(kafka.controller.ControllerBrokerRequestBatch:99)
[2017-05-17 17:24:54,446] ERROR [Partition state machine on Controller 1]:
Error while moving some partitions to the online state
(kafka.controller.PartitionStateMachine:105)
java.lang.IllegalStateException: java.lang.InterruptedException
at
kafka.controller.ControllerBrokerRequestBatch.sendRequestsToBrokers(ControllerChannelManager.scala:459)
at
kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:88)
at
kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:59)
at
kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:266)
at kafka.controller.KafkaController.elect(KafkaController.scala:1565)
at
kafka.controller.KafkaController$Reelect$.process(KafkaController.scala:1512)
at
kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1154)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
Caused by: java.lang.InterruptedException
at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1219)
at
java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:340)
at
java.util.concurrent.LinkedBlockingQueue.put(LinkedBlockingQueue.java:338)
at
kafka.controller.ControllerChannelManager.sendRequest(ControllerChannelManager.scala:66)
at
kafka.controller.KafkaController.sendRequest(KafkaController.scala:614)
at
kafka.controller.ControllerBrokerRequestBatch$$anonfun$sendRequestsToBrokers$2.apply(ControllerChannelManager.scala:372)
at
kafka.controller.ControllerBrokerRequestBatch$$anonfun$sendRequestsToBrokers$2.apply(ControllerChannelManager.scala:351)
at
scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
at
scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
at
scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:236)
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
at scala.collection.mutable.HashMap.foreach(HashMap.scala:130)
at
kafka.controller.ControllerBrokerRequestBatch.sendRequestsToBrokers(ControllerChannelManager.scala:351)
... 7 more
[2017-05-17 17:24:54,450] ERROR [Partition state machine on Controller 1]:
Error while moving some partitions to OnlinePartition state
(kafka.controller.PartitionStateMachine:105)
java.lang.IllegalStateException: Controller to broker state change requests
batch is not empty while creating a new one. Some LeaderAndIsr state changes
Map(1 -> Map(topic-1 ->
(LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:1,ControllerEpoch:2),ReplicationFactor:2),AllReplicas:0,1)))
might be lost
at
kafka.controller.ControllerBrokerRequestBatch.newBatch(ControllerChannelManager.scala:262)
at
kafka.controller.PartitionStateMachine.handleStateChanges(PartitionStateMachine.scala:109)
at
kafka.controller.KafkaController.onPreferredReplicaElection(KafkaController.scala:584)
at
kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:274)
at kafka.controller.KafkaController.elect(KafkaController.scala:1565)
at
kafka.controller.KafkaController$Reelect$.process(KafkaController.scala:1512)
at
kafka.controller.KafkaController$ControllerEventThread.doWork(KafkaController.scala:1154)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
[2017-05-17 17:24:54,480] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:24:54,487] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:25:05,572] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:25:05,580] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-05-17 17:25:07,244] ERROR ZKShutdownHandler is not registered, so
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
