You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ambari.apache.org by "Dmitry Lysnichenko (Jira)" <ji...@apache.org> on 2020/01/29 18:21:00 UTC

[jira] [Updated] (AMBARI-25466) TBD

     [ https://issues.apache.org/jira/browse/AMBARI-25466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dmitry Lysnichenko updated AMBARI-25466:
----------------------------------------
    Description: TBD  (was: *The issue was reproduced on two-node cluster with Kafka Broker for one node and Kafka Client for both nodes. I didn't reproduce it on single-node cluster.
{code}
[2020-01-28 04:09:45,024] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler)
[2020-01-28 04:09:45,283] INFO Creating /brokers/ids/1001 (is it secure? true) (kafka.zk.KafkaZkClient)
[2020-01-28 04:09:45,396] ERROR Error while creating ephemeral at /brokers/ids/1001, node already exists and owner '72057704463990786' does not match current session '144115314837946368' (kafka.zk.KafkaZkClient$CheckedEphemeral)
[2020-01-28 04:09:45,414] ERROR [KafkaServer id=1001] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists
	at org.apache.zookeeper.KeeperException.create(KeeperException.java:126)
	at kafka.zk.KafkaZkClient$CheckedEphemeral.getAfterNodeExists(KafkaZkClient.scala:1784)
	at kafka.zk.KafkaZkClient$CheckedEphemeral.create(KafkaZkClient.scala:1722)
	at kafka.zk.KafkaZkClient.checkedEphemeralCreate(KafkaZkClient.scala:1689)
	at kafka.zk.KafkaZkClient.registerBroker(KafkaZkClient.scala:97)
	at kafka.server.KafkaServer.startup(KafkaServer.scala:262)
	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:42)
	at kafka.Kafka$.main(Kafka.scala:84)
	at com.cloudera.kafka.wrap.Kafka$$anonfun$1.apply(Kafka.scala:92)
	at com.cloudera.kafka.wrap.Kafka$$anonfun$1.apply(Kafka.scala:92)
	at com.cloudera.kafka.wrap.Kafka$.runMain(Kafka.scala:103)
	at com.cloudera.kafka.wrap.Kafka$.main(Kafka.scala:95)
	at com.cloudera.kafka.wrap.Kafka.main(Kafka.scala)
[2020-01-28 04:09:45,423] INFO [KafkaServer id=1001] shutting down (kafka.server.KafkaServer)
{code}
Kafka works fine after next start.*)

> TBD
> ---
>
>                 Key: AMBARI-25466
>                 URL: https://issues.apache.org/jira/browse/AMBARI-25466
>             Project: Ambari
>          Issue Type: Bug
>    Affects Versions: 2.7.5
>            Reporter: Dmitry Lysnichenko
>            Assignee: Dmitry Lysnichenko
>            Priority: Major
>             Fix For: 2.7.6
>
>
> TBD



--
This message was sent by Atlassian Jira
(v8.3.4#803005)