[jira] [Created] (KAFKA-2283) scheduler exception on non-controller node when shutdown

["allenlee (JIRA)" <ji...@apache.org>]

allenlee created KAFKA-2283:
-------------------------------

             Summary: scheduler exception on non-controller node when shutdown
                 Key: KAFKA-2283
                 URL: https://issues.apache.org/jira/browse/KAFKA-2283
             Project: Kafka
          Issue Type: Bug
          Components: controller
    Affects Versions: 0.8.2.1
         Environment: linux debian
            Reporter: allenlee
            Assignee: Neha Narkhede
            Priority: Minor


When broker shutdown, there is an error log about 'Kafka scheduler has not been started'.
It only appears on non-controller node. If this broker is the controller, it shutdown without warning log.

IMHO, *autoRebalanceScheduler.shutdown()* should only valid for controller, right?

{quote}
[2015-06-17 22:32:51,814] INFO Shutdown complete. (kafka.log.LogManager)
[2015-06-17 22:32:51,815] WARN Kafka scheduler has not been started (kafka.utils.Utils$)
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.shutdown(KafkaController.scala:664)
        at kafka.server.KafkaServer$$anonfun$shutdown$8.apply$mcV$sp(KafkaServer.scala:285)
        at kafka.utils.Utils$.swallow(Utils.scala:172)
        at kafka.utils.Logging$class.swallowWarn(Logging.scala:92)
        at kafka.utils.Utils$.swallowWarn(Utils.scala:45)
        at kafka.utils.Logging$class.swallow(Logging.scala:94)
        at kafka.utils.Utils$.swallow(Utils.scala:45)
        at kafka.server.KafkaServer.shutdown(KafkaServer.scala:285)
        at kafka.server.KafkaServerStartable.shutdown(KafkaServerStartable.scala:42)
        at kafka.Kafka$$anon$1.run(Kafka.scala:42)
[2015-06-17 22:32:51,818] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
{quote}




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)