[KAFKA-2319] After controlled shutdown: IllegalStateException: Kafka scheduler has not been started - ASF JIRA

Attach files

Attach Screenshot

Add vote

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Reopened
Priority: Major
Resolution: Unresolved
Affects Version/s: 1.0.1
Fix Version/s: None
Component/s: core
Labels:
None

Description

Running 0.8.2.1, just saw this today at the end of a controlled shutdown. It doesn't happen every time, but I've seen it several times:

2015-07-07 18:54:28,424  INFO [Thread-4] server.KafkaServer - [Kafka Server 99], Controlled shutdown succeeded
2015-07-07 18:54:28,425  INFO [Thread-4] network.SocketServer - [Socket Server on Broker 99], Shutting down
2015-07-07 18:54:28,435  INFO [Thread-4] network.SocketServer - [Socket Server on Broker 99], Shutdown completed
2015-07-07 18:54:28,435  INFO [Thread-4] server.KafkaRequestHandlerPool - [Kafka Request Handler on Broker 99], shutting down
2015-07-07 18:54:28,444  INFO [Thread-4] server.KafkaRequestHandlerPool - [Kafka Request Handler on Broker 99], shut down completely
2015-07-07 18:54:28,649  INFO [Thread-4] server.ReplicaManager - [Replica Manager on Broker 99]: Shut down
2015-07-07 18:54:28,649  INFO [Thread-4] server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 99] shutting down
2015-07-07 18:54:28,650  INFO [Thread-4] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-95], Shutting down
2015-07-07 18:54:28,750  INFO [Thread-4] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-95], Shutdown completed
2015-07-07 18:54:28,750  INFO [ReplicaFetcherThread-0-95] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-95], Stopped
2015-07-07 18:54:28,750  INFO [Thread-4] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-98], Shutting down
2015-07-07 18:54:28,791  INFO [Thread-4] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-98], Shutdown completed
2015-07-07 18:54:28,791  INFO [ReplicaFetcherThread-0-98] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-98], Stopped
2015-07-07 18:54:28,791  INFO [Thread-4] server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 99] shutdown completed
2015-07-07 18:54:28,819  INFO [Thread-4] server.ReplicaManager - [Replica Manager on Broker 99]: Shut down completely
2015-07-07 18:54:28,826  INFO [Thread-4] log.LogManager - Shutting down.
2015-07-07 18:54:30,459  INFO [Thread-4] log.LogManager - Shutdown complete.
2015-07-07 18:54:30,463  WARN [Thread-4] utils.Utils$ - Kafka scheduler has not been started
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)
 ...