kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Neha Narkhede <neha.narkh...@gmail.com>
Subject Re: Question on StateChangeFailedException
Date Sun, 09 Mar 2014 00:23:26 GMT
Cool. Would you mind describing the bug so it helps other Kafka users as
well?


On Sat, Mar 8, 2014 at 8:45 AM, Bae, Jae Hyeon <metacret@gmail.com> wrote:

> Never mind, this was caused by a bug of my apache curator-zkclient bridge
> module.
>
>
> On Fri, Mar 7, 2014 at 6:14 PM, Bae, Jae Hyeon <metacret@gmail.com> wrote:
>
> > I started from a fresh but I deployed the working version synced from the
> > latest trunk, not a release version.
> >
> > I just executed kafka.admin.TopicCommand with --create option.
> >
> >
> >
> >
> > On Fri, Mar 7, 2014 at 5:56 PM, Neha Narkhede <neha.narkhede@gmail.com
> >wrote:
> >
> >> Starting from a fresh and working deployment, what admin commands or
> steps
> >> lead you to these errors? This error basically points to an unexpected
> >> state change, which could be a bug. I'm looking for steps to be able to
> >> reproduce the bug.
> >>
> >> Thanks,
> >> Neha
> >>
> >>
> >> On Fri, Mar 7, 2014 at 1:59 PM, Bae, Jae Hyeon <metacret@gmail.com>
> >> wrote:
> >>
> >> > How can I prevent these errors coming?
> >> >
> >> > When I created 9 partitions on 3 instances and 2 replication-factor, I
> >> > didn't have any error. But when I created 36 partitions on 12
> >> instances, I
> >> > got these errors.
> >> >
> >> >
> >> > 2014-03-07 18:19:28,208] ERROR Controller 9 epoch 12 initiated state
> >> change
> >> > of replica 9 for partition [request_trace,3] from NonExistentReplica
> to
> >> > NewReplica failed (state.change.logger)
> >> > kafka.common.StateChangeFailedException: Replica 9 for partition
> >> > [request_trace,3] cannot be moved to NewReplicastate as it is being
> >> > requested to become leader
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.ReplicaStateMachine.handleStateChange(ReplicaStateMachine.scala:160)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.ReplicaStateMachine$$anonfun$handleStateChanges$2.apply(ReplicaStateMachine.scala:96)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.ReplicaStateMachine$$anonfun$handleStateChanges$2.apply(ReplicaStateMachine.scala:96)
> >> >         at
> >> > scala.collection.immutable.HashSet$HashSet1.foreach(HashSet.scala:123)
> >> >         at
> >> >
> >>
> scala.collection.immutable.HashSet$HashTrieSet.foreach(HashSet.scala:322)
> >> >         at
> >> >
> >>
> scala.collection.immutable.HashSet$HashTrieSet.foreach(HashSet.scala:322)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.ReplicaStateMachine.handleStateChanges(ReplicaStateMachine.scala:96)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.KafkaController.onNewPartitionCreation(KafkaController.scala:464)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.KafkaController.onNewTopicCreation(KafkaController.scala:452)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply$mcV$sp(PartitionStateMachine.scala:421)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply(PartitionStateMachine.scala:403)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply(PartitionStateMachine.scala:403)
> >> >         at kafka.utils.Utils$.inLock(Utils.scala:538)
> >> >         at
> >> >
> >> >
> >>
> kafka.controller.PartitionStateMachine$TopicChangeListener.handleChildChange(PartitionStateMachine.scala:402)
> >> >         at org.I0Itec.zkclient.ZkClient$7.run(ZkClient.java:576)
> >> >         at
> org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
> >> >
> >>
> >
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message