[jira] [Created] (KAFKA-466) Controller tests throw IllegalStateException

[Neha Narkhede (JIRA)]

Neha Narkhede created KAFKA-466:
-----------------------------------

             Summary: Controller tests throw IllegalStateException
                 Key: KAFKA-466
                 URL: https://issues.apache.org/jira/browse/KAFKA-466
             Project: Kafka
          Issue Type: Bug
    Affects Versions: 0.8
            Reporter: Neha Narkhede
            Assignee: Yang Ye


[info] == core-kafka / kafka.controller.ControllerBasicTest ==
[info] Test Starting: 
testControllerFailOver(kafka.controller.ControllerBasicTest)
[info] Test Passed: testControllerFailOver(kafka.controller.ControllerBasicTest)
[info] Test Starting: 
testControllerCommandSend(kafka.controller.ControllerBasicTest)
[2012-08-17 08:28:39,254] ERROR Uncaught exception in thread 
'kafka-request-handler-2': (kafka.utils.Utils$:99)
java.lang.IllegalStateException: The leaderAndISR info for partition [test1, 0] 
is not in Zookeeper
        at kafka.cluster.Partition.updateISR(Partition.scala:248)
        at 
kafka.cluster.Partition.updateLeaderHWAndMaybeExpandISR(Partition.scala:162)
        at 
kafka.server.ReplicaManager.recordFollowerPosition(ReplicaManager.scala:190)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2$$anonfun$apply$14.apply(KafkaApis.scala:295)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2$$anonfun$apply$14.apply(KafkaApis.scala:294)
        at 
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
        at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2.apply(KafkaApis.scala:294)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2.apply(KafkaApis.scala:291)
        at 
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
        at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32)
        at kafka.server.KafkaApis.maybeUpdatePartitionHW(KafkaApis.scala:291)
        at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:230)
        at kafka.server.KafkaApis.handle(KafkaApis.scala:59)
        at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:38)
        at java.lang.Thread.run(Thread.java:662)
[2012-08-17 08:28:39,257] ERROR Uncaught exception in thread 
'kafka-request-handler-4': (kafka.utils.Utils$:99)
java.lang.IllegalStateException: The leaderAndISR info for partition [test1, 0] 
is not in Zookeeper
        at kafka.cluster.Partition.updateISR(Partition.scala:248)
        at 
kafka.cluster.Partition.updateLeaderHWAndMaybeExpandISR(Partition.scala:162)
        at 
kafka.server.ReplicaManager.recordFollowerPosition(ReplicaManager.scala:190)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2$$anonfun$apply$14.apply(KafkaApis.scala:295)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2$$anonfun$apply$14.apply(KafkaApis.scala:294)
        at 
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
        at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2.apply(KafkaApis.scala:294)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2.apply(KafkaApis.scala:291)
        at 
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
        at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32)
        at kafka.server.KafkaApis.maybeUpdatePartitionHW(KafkaApis.scala:291)
        at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:230)
        at kafka.server.KafkaApis.handle(KafkaApis.scala:59)
        at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:38)
        at java.lang.Thread.run(Thread.java:662)
[2012-08-17 08:28:39,261] ERROR Uncaught exception in thread 
'kafka-request-handler-3': (kafka.utils.Utils$:99)
java.lang.IllegalStateException: The leaderAndISR info for partition [test1, 0] 
is not in Zookeeper
        at kafka.cluster.Partition.updateISR(Partition.scala:248)
        at 
kafka.cluster.Partition.updateLeaderHWAndMaybeExpandISR(Partition.scala:162)
        at 
kafka.server.ReplicaManager.recordFollowerPosition(ReplicaManager.scala:190)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2$$anonfun$apply$14.apply(KafkaApis.scala:295)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2$$anonfun$apply$14.apply(KafkaApis.scala:294)
        at 
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
        at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2.apply(KafkaApis.scala:294)
        at 
kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$2.apply(KafkaApis.scala:291)
        at 
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
        at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32)
        at kafka.server.KafkaApis.maybeUpdatePartitionHW(KafkaApis.scala:291)
        at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:230)
        at kafka.server.KafkaApis.handle(KafkaApis.scala:59)
        at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:38)
        at java.lang.Thread.run(Thread.java:662)


--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira