Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-466

Controller tests throw IllegalStateException

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.8.0
    • Component/s: None

      Description

      [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)

        Attachments

          Activity

            People

            • Assignee:
              yeyangever Yang Ye
              Reporter:
              nehanarkhede Neha Narkhede
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: