lizhimins opened a new pull request, #10476: URL: https://github.com/apache/rocketmq/pull/10476
## What is the purpose of the change Part of #10462 Fix resource leaks and improve lifecycle management in tiered storage module. ## Brief changelog - FileSegment `close()` waits for in-flight commit (30s timeout) - PosixFileSegment: store RAF references to prevent handle leaks - MessageStoreExecutor `shutdown()`: add `awaitTermination(30s)` - Remove MessageStoreExecutor singleton pattern - Remove `fileRecyclingExecutor` (wrong thread name, unused) - Change MessageStoreExecutor fields from public to private with getters - FlatFileFactory: remove test constructor that leaked thread pool - FlatMessageFile: remove dead `inFlightRequestMap` field - TieredMessageStore: reorder shutdown (dispatcher->index->executor->file->next) - Update all tests to pass executor to FlatFileFactory and shutdown in @After ## Verifying this change - [x] `mvn compile` succeeds - [x] `mvn test -pl tieredstore` passes (112 tests, 0 failures) 🤖 Generated with [Claude Code](https://claude.com/claude-code) -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
