Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
0.8.0
-
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)