[
https://issues.apache.org/jira/browse/KAFKA-1365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13969911#comment-13969911
]
Balaji Seshadri edited comment on KAFKA-1365 at 4/15/14 7:02 PM:
-----------------------------------------------------------------
I can help fix this as its happening for us in DISH Upgrade,please direct me
accordingly.
Please see email from Bob.
-----Original Message-----
From: Bello, Bob [mailto:[email protected]]
Sent: Tuesday, April 15, 2014 10:00 AM
To: [email protected]
Cc: Bello, Bob
Subject: RE: Kafka upgrade 0.8.0 to 0.8.1 - kafka-preferred-replica-election
failure
I performed another test. I build a single Kafka 0.8.1 Broker with a single ZK
instance. Brand new, no topics.
Upon start up of the Kafka broker, the zookeeper /admin node only contains
"/admin/delete_topics".
Even without creating a topic, I run a perfered replica election, and it's
successful. After the run, I check the node for
/admin/preferred_replica_election and it exists.
[zk: tm1mwwm001:2181(CONNECTED) 0] get /admin/preferred_replica_election
{"version":1,"partitions":[]} cZxid = 0x19 ctime = Tue Apr 15 09:53:22 MDT 2014
mZxid = 0x19 mtime = Tue Apr 15 09:53:22 MDT 2014 pZxid = 0x19 cversion = 0
dataVersion = 0 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 29 numChildren
= 0
If I run the election again, I get the following error (the same error as my
original post).
Failed to start preferred replica election
kafka.common.AdminCommandFailedException: Admin command failed
at
kafka.admin.PreferredReplicaLeaderElectionCommand.moveLeaderToPreferredReplica(PreferredReplicaLeaderElectionCommand.scala:115)
at
kafka.admin.PreferredReplicaLeaderElectionCommand$.main(PreferredReplicaLeaderElectionCommand.scala:60)
at
kafka.admin.PreferredReplicaLeaderElectionCommand.main(PreferredReplicaLeaderElectionCommand.scala)
Caused by: kafka.admin.AdminOperationException: Preferred replica leader
election currently in progress for Set(). Aborting operation
at
kafka.admin.PreferredReplicaLeaderElectionCommand$.writePreferredReplicaElectionData(PreferredReplicaLeaderElectionCommand.scala:101)
at
kafka.admin.PreferredReplicaLeaderElectionCommand.moveLeaderToPreferredReplica(PreferredReplicaLeaderElectionCommand.scala:113)
... 2 more
The zookeeper log shows the following:
2014-04-15 09:53:44 INFO server.PrepRequestProcessor - Got user-level
KeeperException when processing sessionid:0x1456615e7770006 type:create
cxid:0x2 zxid:0x1e txntype:-1 reqpath:n/a Error
Path:/admin/preferred_replica_election Error:KeeperErrorCode = NodeExists for
/admin/preferred_replica_election
It looks like the preferred election process is not removing the node after
completion.
Bob Bello
Middleware Applications Administrator
Direct: 720-514-6605
email: [email protected]
was (Author: balaji.seshadri):
I can help fix this as its happening for us in DISH Upgrade,please direct me
accordingly.
> Second Manual preferred replica leader election command always fails
> --------------------------------------------------------------------
>
> Key: KAFKA-1365
> URL: https://issues.apache.org/jira/browse/KAFKA-1365
> Project: Kafka
> Issue Type: Bug
> Components: controller, tools
> Affects Versions: 0.8.1
> Reporter: Ryan Berdeen
> Assignee: Neha Narkhede
> Priority: Critical
> Fix For: 0.8.2
>
>
> After running kafka-preferred-replica-election.sh once, a second run will
> fail with "Preferred replica leader election currently in progress for ...".
> The /admin/preferred_replica_election key is never deleted from ZooKeeper,
> because the "isTriggeredByAutoRebalance" parameter to
> onPreferredReplicaElection
> (https://github.com/apache/kafka/blob/0ffec142a991849833d9767be07e895428ccaea1/core/src/main/scala/kafka/controller/KafkaController.scala#L614)
> is used incorrectly. In the automatic case
> (https://github.com/apache/kafka/blob/0ffec142a991849833d9767be07e895428ccaea1/core/src/main/scala/kafka/controller/KafkaController.scala#L1119),
> it is set to false. In the manual case
> (https://github.com/apache/kafka/blob/0ffec142a991849833d9767be07e895428ccaea1/core/src/main/scala/kafka/controller/KafkaController.scala#L1266)
> the parameter is not passed, so it defaults to true.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
