kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yu Yang <yuyan...@gmail.com>
Subject Re: cannot make another partition reassignment due to the previous partition reassignment failure
Date Tue, 16 Jun 2015 05:04:41 GMT
Thanks, Manikumar!

On Mon, Jun 15, 2015 at 9:14 PM, Manikumar Reddy <kumar@nmsworks.co.in>
wrote:

> Hi,
>   Jut delete the "/admin/reassign_partitions" zk node for zookeeper  and
> try again.
>
> #sh zookeeper-shell.sh localhost:2181
>   delete /admin/reassign_partitions
>
>
> Manikumar
>
>
> On Tue, Jun 16, 2015 at 8:15 AM, Yu Yang <yuyang08@gmail.com> wrote:
>
> > HI,
> >
> > We have a kafka 0.8.1.1 cluster. Recently I did a partition assignment
> for
> > some topic partitions in the cluster. Due to broker failure, the
> partition
> > reassignment failed. I cannot do another partition assignment now, and
> > always get errors as follows. How can we work around this? I have tried
> > google for answers, but did not succeed.
> >
> > Partitions reassignment failed due to Partition reassignment currently in
> > progress for Map(). Aborting operation
> > kafka.common.AdminCommandFailedException: Partition reassignment
> currently
> > in progress for Map(). Aborting operation
> > at
> >
> >
> kafka.admin.ReassignPartitionsCommand.reassignPartitions(ReassignPartitionsCommand.scala:204)
> > at
> >
> >
> kafka.admin.ReassignPartitionsCommand$.executeAssignment(ReassignPartitionsCommand.scala:124)
> > at
> >
> >
> kafka.admin.ReassignPartitionsCommand$.main(ReassignPartitionsCommand.scala:49)
> > at
> >
> kafka.admin.ReassignPartitionsCommand.main(ReassignPartitionsCommand.scala)
> >
> >
> > Thanks!
> >
> > Regards,
> > Yu
> >
>

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