You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/08/23 18:26:42 UTC
[jira] [Resolved] (KAFKA-466) Controller tests throw
IllegalStateException
[ 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