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

Error when trying to shut down auto balancing scheduler of controller

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.8.2.1
    • None
    • None
    • None

    Description

      We observed the following exception when a controller was shutting down:

      [run] Error handling event ZkEvent[New session event sent to kafka.controller.KafkaController$SessionExpirationListener@3278c211]
      java.lang.IllegalStateException: Kafka scheduler has not been started
          at kafka.utils.KafkaScheduler.ensureStarted(KafkaScheduler.scala:114)
          at kafka.utils.KafkaScheduler.shutdown(KafkaScheduler.scala:86)
          at kafka.controller.KafkaController.onControllerResignation(KafkaController.scala:350)
          at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1108)
          at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1107)
          at kafka.controller.KafkaController$SessionExpirationListener$$anonfun$handleNewSession$1.apply(KafkaController.scala:1107)
          at kafka.utils.Utils$.inLock(Utils.scala:535)
          at kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1107)
          at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
          at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
      

      The scheduler should have been started.

      Attachments

        Activity

          People

            Unassigned Unassigned
            fpj Flavio Paiva Junqueira
            Votes:
            1 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: