[jira] [Created] (KAFKA-5483) Shutdown of scheduler should come after LogManager

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

Jason Gustafson created KAFKA-5483:
--------------------------------------

             Summary: Shutdown of scheduler should come after LogManager
                 Key: KAFKA-5483
                 URL: https://issues.apache.org/jira/browse/KAFKA-5483
             Project: Kafka
          Issue Type: Bug
            Reporter: Jason Gustafson


It seems like we shutdown the scheduler used by LogManager before shutting down LogManager itself. This can lead to an IllegalStateException
{code}
"[2017-06-06 18:10:19,025] ERROR [ReplicaFetcherThread-14-111], Error due to  (kafka.server.ReplicaFetcherThread)
kafka.common.KafkaException: error processing data for partition [akiraPricedProduct.global,10] offset 191893
        at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1$$anonfun$apply$2.apply(AbstractFetcherThread.scala:170)
        at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1$$anonfun$apply$2.apply(AbstractFetcherThread.scala:141)
        at scala.Option.foreach(Option.scala:257)
        at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1.apply(AbstractFetcherThread.scala:141)
        at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1.apply(AbstractFetcherThread.scala:138)
        at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
        at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
        at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2.apply$mcV$sp(AbstractFetcherThread.scala:138)
        at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2.apply(AbstractFetcherThread.scala:138)
        at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2.apply(AbstractFetcherThread.scala:138)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234)
        at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:136)
        at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:103)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
Caused by: java.lang.IllegalStateException: Kafka scheduler is not running.
        at kafka.utils.KafkaScheduler.ensureRunning(KafkaScheduler.scala:132)
        at kafka.utils.KafkaScheduler.schedule(KafkaScheduler.scala:106)
        at kafka.log.Log.roll(Log.scala:794)
        at kafka.log.Log.maybeRoll(Log.scala:744)
        at kafka.log.Log.append(Log.scala:405)
        at kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:130)
        at kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:42)
        at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1$$anonfun$apply$2.apply(AbstractFetcherThread.scala:153)
{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)