L-xiaohai opened a new issue, #7538: URL: https://github.com/apache/rocketmq/issues/7538
### Before Creating the Bug Report - [X] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions). - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/discussions) of this repository and believe that this is not a duplicate. - [X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ. ### Runtime platform environment NAME="Rocky Linux" VERSION="8.6 (Green Obsidian)" ### RocketMQ version rocketmq client version 5.1.4 ### JDK Version openjdk version "1.8.0_302" OpenJDK Runtime Environment (Zulu 8.56.0.21-CA-linux64) (build 1.8.0_302-b08) OpenJDK 64-Bit Server VM (Zulu 8.56.0.21-CA-linux64) (build 25.302-b08, mixed mode) ### Describe the Bug now project use DefaultMQPushConsumer method poll message, when report PullMessageService error, ProcessQueue stop poll message. review code, due to trigger cached message size limiting, pullRequest should execute later, and print 'so do flow control' in the log, but msgTreeMap has no element, msgTreeMap of msgbody size don't add up to more than cached message size of limiting ### Steps to Reproduce indetermination，project need to use rocketmq to delivery message to other project, when receive messge in A topic, message will follows a certain logic to delivery other topic in other thread pool first, create two topic with 16 queue second, receiving message modify topic value to delivery message to other topic ### What Did You Expect to See?  2023-11-04 11:09:30,671 [PullMessageService] ERROR PullMessageService - Pull Message Service Run Method exception java.util.NoSuchElementException: null at java.util.TreeMap.key(TreeMap.java:1327) at java.util.TreeMap.firstKey(TreeMap.java:290) at org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.pullMessage(DefaultMQPushConsumerImpl.java:286) at org.apache.rocketmq.client.impl.consumer.PullMessageService.pullMessage(PullMessageService.java:101) at org.apache.rocketmq.client.impl.consumer.PullMessageService.run(PullMessageService.java:127) at java.lang.Thread.run(Thread.java:748) ### What Did You See Instead? nothing ### Additional Context _No response_ -- 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: commits-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
