[
https://issues.apache.org/jira/browse/KAFKA-466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-466.
---------------------------
Resolution: Duplicate
Fix Version/s: 0.8
This issue should be addressed as part of KAFKA-428
> 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
> Labels: bugs, replication-testing
> Fix For: 0.8
>
>
> [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
