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;

Reply via email to