This is an automated email from the ASF dual-hosted git repository. lamberliu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
The following commit(s) were added to refs/heads/master by this push: new 9b8508f [TUBEMQ-317]The Store Manager throws java.lang.NullPointerException (#236) 9b8508f is described below commit 9b8508f3d95c8c3fb893bf930834e9b694fe5826 Author: gosonzhang <4675...@qq.com> AuthorDate: Fri Aug 14 15:39:12 2020 +0800 [TUBEMQ-317]The Store Manager throws java.lang.NullPointerException (#236) Co-authored-by: gosonzhang <gosonzh...@tencent.com> --- .../org/apache/tubemq/server/broker/msgstore/disk/FileSegmentList.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/msgstore/disk/FileSegmentList.java b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/msgstore/disk/FileSegmentList.java index 6020641..2d02541 100644 --- a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/msgstore/disk/FileSegmentList.java +++ b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/msgstore/disk/FileSegmentList.java @@ -66,7 +66,7 @@ public class FileSegmentList implements SegmentList { @Override public Segment getRecordSeg(final long offset) throws IOException { Segment tmpSeg = this.findSegment(offset); - if (tmpSeg.isExpired()) { + if (tmpSeg != null && tmpSeg.isExpired()) { return null; } return tmpSeg;