[GitHub] [rocketmq] WJL3333 opened a new issue #3229: ScheduleMessageService sometimes throw IllegalStateException when shutdown.

[GitBox <gi...@apache.org>]

WJL3333 opened a new issue #3229:
URL: https://github.com/apache/rocketmq/issues/3229


   **BUG REPORT**
   
   1. Please describe the issue you observed:
   
   - send a lot of schedule msg.
   - shutdown broker process or trigger DLedger change.
   - got Exception sometimes 
   
   2021-08-07 20:18:20 WARN ScheduleMessageTimerThread - message store has shutdown, so putMessage is forbidden
   2021-08-07 20:18:21 ERROR ScheduleMessageTimerThread - ScheduleMessageService, a message time up, but reput it failed, topic: SCHEDULE_TOPIC_XXXX msgId C0A81F0A00002A9F000000002E369798
   2021-08-07 20:18:21 ERROR ScheduleMessageTimerThread - ScheduleMessageService, messageTimeup execute error, drop it. msgExt=MessageExt [brokerName=null, queueId=0, storeSize=262, queueOffset=657588, sysFlag=0, bornTimestamp=1628337462474, bornHost=/192.168.31.10:50221, storeTimestamp=1628337462474, storeHost=/192.168.31.10:10911, msgId=C0A81F0A00002A9F000000002E369798, commitLogOffset=775329688, bodyCRC=198614610, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='SCHEDULE_TOPIC_XXXX', flag=0, properties={REAL_TOPIC=TopicTest, KEYS=OrderID188, UNIQ_KEY=7F0000016FC818B4AAC2232EB0CADAE6, CLUSTER=DefaultCluster, WAIT=false, TAGS=TagA, REAL_QID=2}, body=[72, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], transactionId='null'}], nextOffset=657588,offsetPy=775329688,sizePy=262
   java.lang.IllegalStateException: Timer already cancelled.
   	at java.util.Timer.sched(Timer.java:397) ~[na:1.8.0_301]
   	at java.util.Timer.schedule(Timer.java:193) ~[na:1.8.0_301]
   	at org.apache.rocketmq.store.schedule.ScheduleMessageService$DeliverDelayedMessageTimerTask.executeOnTimeup(ScheduleMessageService.java:333) [rocketmq-store-4.9.1-SNAPSHOT.jar:4.9.1-SNAPSHOT]
   	at org.apache.rocketmq.store.schedule.ScheduleMessageService$DeliverDelayedMessageTimerTask.run(ScheduleMessageService.java:238) [rocketmq-store-4.9.1-SNAPSHOT.jar:4.9.1-SNAPSHOT]
   	at java.util.TimerThread.mainLoop(Timer.java:555) [na:1.8.0_301]
   	at java.util.TimerThread.run(Timer.java:505) [na:1.8.0_301]
   2021-08-07 20:18:21 WARN ScheduleMessageTimerThread - message store has shutdown, so putMessage is forbidden
   
   2. Please tell us about your environment:
   mac local cluster in dledger mode.
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org