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)