[Bug] CheckpointFile skips valid backup recovery when the primary numeric header is malformed
Maintainer thường phản hồi trong vòng 1 ngày
Đánh giá
- Độ khó
- 3/5
- Thời gian dự kiến
- 1-2 ngày
- Mức phù hợp với người mới
- 35/100
Hướng nghiên cứu
Start by reading CheckpointFile.read(String) and the public read() recovery path; also inspect EpochFileCache.initCacheFromFile and the existing remoting CheckpointFileTest tests. Reproduce with a malformed primary numeric header and a valid .bak, then verify recovery, failure cause and path when both headers are invalid, and regression behavior for valid primaries and CRC/count mismatches. PR #11032 is unrelated; open PR #11063 already proposes this fix.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Mô tả
Before Creating the Bug Report
-
I found a bug, not just asking a question, which should be created in GitHub Discussions.
-
I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.
-
I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
Runtime platform environment
Windows 11; local checkpoint files and native common/remoting module tests. No live broker or HA failover claim.
RocketMQ version
develop, revision 5.5.1, commit 57c2dc04f78cc7e73e6b8c9436ee0fff0d0f46c3.
JDK Version
OpenJDK 1.8.0_302 (GraalVM CE 21.2.0), Maven 3.6.3.
Describe the Bug
CheckpointFile.read(String) parses the entry count and CRC with Integer.parseInt. An empty, truncated or nonnumeric header throws NumberFormatException, while public read() only catches IOException to recover from .bak. A valid backup is therefore ignored. EpochFileCache.initCacheFromFile also only catches IOException.
Steps to Reproduce
- Create a CheckpointFile whose serializer writes and reads the entry string unchanged.
- Write Collections.singletonList("saved") and copy the checkpoint file to checkpoint.getBackFilePath().
- Replace the primary file with "invalid\n0\nvalue\n" (or an empty file).
- Call checkpoint.read().
The valid backup can be read on its own; the malformed primary prevents reaching it.
What Did You Expect to See?
Malformed numeric headers enter the existing IOException recovery path and the valid backup is returned. If the backup header is also invalid, the final failure is IOException with the failing path and NumberFormatException as its cause.
What Did You See Instead?
An unchecked NumberFormatException escapes from parsing the primary header instead of loading the valid backup.
Additional Context
The proposed fix only wraps the two numeric header parses; serializer exceptions are not swallowed. Existing valid-primary precedence and CRC/count mismatch behavior are regression controls. Six new header tests plus the three existing remoting CheckpointFileTest tests pass on the independent patch (9 native tests, 0 failures/errors/skips). Baseline native Surefire reproduced the NumberFormatException and stopped after the first failure; not all six new methods ran before the fix. Checkstyle/SpotBugs pass.
PR #11032 concerns empty checkpoint state and does not handle malformed numeric headers. Issue/PR/discussion searches did not identify this header-recovery fix.
AI assistance: OpenAI Codex was used for investigation, implementation and tests.
- Ngôn ngữ chính
- Java
- Star
- 22.7k
- Fork
- 12k
- Merge trung bình
- 4 ngày 20 giờ
- Pull request đã merge (30 ngày)
- 11
Chuẩn bị môi trường
- Không có Dockerfile hay tệp Docker Compose
- Có mẫu pull request
- Đọc hướng dẫn đóng góp
Bắt đầu từ đâu
- Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
- Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
- Fork repository và làm thay đổi trên một nhánh.
- Mở pull request có tham chiếu số hiệu của issue.
Issue khác của apache/rocketmq
-
[Bug] RemotingHelper.connect swaps the socket send and receive buffer configurationCó thể đã có người làm @amalsaidov đã nhận hôm nay. Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100
Maintainer thường phản hồi trong vòng 1 ngày
-
CompressionType.of fails under the Turkish localeCó thể đã có người làm @sharanggupta đã nhận hôm nay. Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 83/100
Maintainer thường phản hồi trong vòng 1 ngày
-
[rocketmq-client-python] TransactionMQProducer allocates an unused producer during initializationĐang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100
Maintainer thường phản hồi trong vòng 1 ngày
-
[Bug] notifyMasterOnline aborts the long-polling wake-up with a NullPointerException when an arrival drains a bucket firstCó thể đã có người làm @iloveeyjafjalla đã nhận 29 ngày trước. Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100
apache/rocketmq#11441 · 1 bình luận ·
Maintainer thường phản hồi trong vòng 1 ngày
-
[Enhancement] FilterFactory duplicate-registration and unregister semantics lack testsCó thể đã có người làm @chennaji9 đã nhận 34 ngày trước. Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 84/100
apache/rocketmq#11340 · 2 bình luận ·
Maintainer thường phản hồi trong vòng 1 ngày
Tất cả issue của apache/rocketmq
Issue tương tự
-
bug emitter:client:csharp
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 84/100
microsoft/typespec#12572 · 1 bình luận · 1 reaction ·
Maintainer thường phản hồi trong vòng 1 ngày
-
GCC 15.2: -Wcast-qual warning - cast discards const qualifier from pointer target type (H5trace.c)Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 73/100
Maintainer thường phản hồi trong vòng 1 ngày
-
needs-area-label
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100
Maintainer thường phản hồi trong vòng 2 ngày
-
area/ai area/backend component/zeebe kind/task
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
spAnser/reacharound#38 ·