Hi Clark, Thank you for your reply! I do see that znode under /admin:
root> ./opt/cloudera/parcels/CDH-5.1.3-1.cdh5.1.3.p0.12/lib/zookeeper/bin/zkCli.sh -server myhost.mydomain.com:2181 ls /admin Connecting to myhost.mydomain.com:2181 <snip> WATCHER:: WatchedEvent state:SyncConnected type:None path:null [reassign_partitions, delete_topics] I'm not sure what this tells me though :) Again, thanks for your time. Chris On Sun, May 17, 2015 at 12:20 AM, Clark Haskins <cl...@kafka.guru> wrote: > Does the partition reassignment znode exist under /admin in zookeeper? > > -Clark > > Sent from my iPhone > > > On May 16, 2015, at 7:16 PM, Chris Neal <cwn...@gmail.com> wrote: > > > > Sorry for bumping my own thread. :S Just wanted to get it in front of > some > > eyes again! > > > > Thanks for your time and help. > > Chris > > > >> On Thu, May 14, 2015 at 10:24 AM, Chris Neal <cwn...@gmail.com> wrote: > >> > >> Hi All, > >> > >> I am running: kafka_2.10-0.8.1.1, and when I run the > >> reassign-partitions.sh script, I get this: > >> > >> 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) > >> > >> I'm running it as: > >> /opt/kafka/kafka/bin/kafka-reassign-partitions.sh --zookeeper $ZOOKEEPER > >> --reassignment-json-file ./$1.json --execute > >> > >> and my json file looks like: > >> {"version":1, > >> "partitions":[ > >> {"topic":"perf_mytopic_raw", "partition":0,"replicas":[0,1]}, > >> {"topic":"perf_mytopic_raw","partition":1,"replicas":[0,1]}]} > >> > >> The empty Map() looks suspicious, and I found another post from about a > >> year ago where it was thought that this might be a bug? I looked > through > >> JIRA and didn't see anything that looked like this issue was created or > >> fixed, so I wanted to ask again about it. > >> > >> Any ideas why this might be failing? There is definitely not another > >> reassignment in progress. :) > >> > >> Thanks very much for your time. > >> Chris > >> >