Skip to content

fix(store): close all consume queue file handles on ConsumeQueueStore shutdown#10060

Merged
ltamber merged 2 commits intoapache:developfrom
RongtongJin:develop-0130
Feb 2, 2026
Merged

fix(store): close all consume queue file handles on ConsumeQueueStore shutdown#10060
ltamber merged 2 commits intoapache:developfrom
RongtongJin:develop-0130

Conversation

@RongtongJin
Copy link
Contributor

Which Issue(s) This PR Fixes

Fixes #issue_id

Brief Description

How Did You Test This Change?

@codecov-commenter
Copy link

codecov-commenter commented Jan 30, 2026

Codecov Report

❌ Patch coverage is 0% with 4 lines in your changes missing coverage. Please review.
✅ Project coverage is 48.85%. Comparing base (3a184c3) to head (f74565c).

Files with missing lines Patch % Lines
...n/java/org/apache/rocketmq/store/ConsumeQueue.java 0.00% 2 Missing ⚠️
...apache/rocketmq/store/queue/BatchConsumeQueue.java 0.00% 1 Missing ⚠️
...ache/rocketmq/store/queue/RocksDBConsumeQueue.java 0.00% 1 Missing ⚠️
Additional details and impacted files
@@              Coverage Diff              @@
##             develop   #10060      +/-   ##
=============================================
- Coverage      48.96%   48.85%   -0.11%     
+ Complexity     13359    13331      -28     
=============================================
  Files           1373     1373              
  Lines          99743    99747       +4     
  Branches       12888    12888              
=============================================
- Hits           48837    48736     -101     
- Misses         44996    45090      +94     
- Partials        5910     5921      +11     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

Copy link
Contributor

@guyinyou guyinyou left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

@ltamber ltamber merged commit 7583fda into apache:develop Feb 2, 2026
11 of 12 checks passed
dingshuangxi888 pushed a commit to dingshuangxi888/rocketmq that referenced this pull request Feb 10, 2026
… shutdown (apache#10060)

* fix(store): close all consume queue file handles on ConsumeQueueStore shutdown

* remove implementation

---------

Co-authored-by: RongtongJin <user@example.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants