java.lang.IllegalStateException: Controller to broker state change requests batch is not empty while creating a new one. Some LeaderAndIsr state changes Map(1 -> Map(topic1-0 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:1))) might be lost

Apache's JIRA Issue Tracker | Flavio Junqueira | 10 months ago
  1. 0

    We observed another instance of the problem reported in KAFKA-2300, but this time the error appeared in the partition state machine. In KAFKA-2300, we haven't cleaned up the state in {{PartitionStateMachine}} and {{ReplicaStateMachine}} as we do in {{KafkaController}}. Here is the stack trace: {noformat} 2016-01-29 15:26:51,393] ERROR [Partition state machine on Controller 0]: Error while moving some partitions to OnlinePartition state (kafka.controller.PartitionStateMachine)java.lang.IllegalStateException: Controller to broker state change requests batch is not empty while creating a new one. Some LeaderAndIsr state changes Map(0 -> Map(foo-0 -> (LeaderAndIsrInfo: (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:0))) might be lost at kafka.controller.ControllerBrokerRequestBatch.newBatch(ControllerChannelManager.scala:254) at kafka.controller.PartitionStateMachine.handleStateChanges(PartitionStateMachine.scala:144) at kafka.controller.KafkaController.onNewPartitionCreation(KafkaController.scala:517) at kafka.controller.KafkaController.onNewTopicCreation(KafkaController.scala:504) at kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply$mcV$sp(PartitionStateMachine.scala:437) at kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply(PartitionStateMachine.scala:419) at kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply(PartitionStateMachine.scala:419) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:262) at kafka.controller.PartitionStateMachine$TopicChangeListener.handleChildChange(PartitionStateMachine.scala:418) at org.I0Itec.zkclient.ZkClient$10.run(ZkClient.java:842) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71) {noformat}

    Apache's JIRA Issue Tracker | 10 months ago | Flavio Junqueira
    java.lang.IllegalStateException: Controller to broker state change requests batch is not empty while creating a new one. Some LeaderAndIsr state changes Map(1 -> Map(topic1-0 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:1))) might be lost
  2. 0

    ISE on replay

    GitHub | 3 years ago | tumb1er
    java.lang.IllegalStateException: Can't change state to Starting from 1
  3. 0

    NearCache.java "IllegalStateException: cache and sorted map size should be the same"?

    Google Groups | 5 years ago | r134a
    java.lang.IllegalStateException: cache and sorted map size should be the same: 1 vs. 0
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    [LPS-59282] Unable to initialize Elasticsearch cluster after node with "0" index is shutdown - Liferay Issues

    liferay.com | 8 months ago
    java.lang.IllegalStateException: Unable to initialize Elasticsearch cluster: { : , : , : , : 1, : 1, : 1, : 1, : 0, : 0, : 1, : 0, : 0, : 0 }
  6. 0

    Deploying Web Application on wildfly 8.2-final ... | JBoss Developer

    jboss.org | 1 year ago
    java.lang.IllegalStateException: Transaction DummyTransaction{xid=DummyXid{id=46812}, status=1} is not in a valid state to be invoking cache operations on.

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.IllegalStateException

      Controller to broker state change requests batch is not empty while creating a new one. Some LeaderAndIsr state changes Map(1 -> Map(topic1-0 -> (LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:1))) might be lost

      at kafka.controller.ControllerBrokerRequestBatch.newBatch()
    2. Apache Kafka
      ControllerFailoverTest.testStartupRace
      1. kafka.controller.ControllerBrokerRequestBatch.newBatch(ControllerChannelManager.scala:254)
      2. kafka.controller.PartitionStateMachine.triggerOnlinePartitionStateChange(PartitionStateMachine.scala:126)
      3. kafka.controller.PartitionStateMachine.startup(PartitionStateMachine.scala:71)
      4. kafka.controller.ControllerFailoverTest.testStartupRace(ControllerFailoverTest.scala:119)
      4 frames