The reassign_partitions znode is the important one. Please paste the contents
of it. That node should only exist while there is a reassignment in progress.
You can probably fix this up by forcing a new controller to come online by
deleting /controller
-Clark
Sent from my iPhone
> On May 17, 2015, at 10:14 AM, Chris Neal <cwn...@gmail.com> wrote:
>
> 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
>>
