[kylin] branch 2.5.x updated: KYLIN-3718 Segments in volatile range is more than designated value

[sh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

shaofengshi pushed a commit to branch 2.5.x
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/2.5.x by this push:
     new e47d9f5  KYLIN-3718 Segments in volatile range is more than designated value
e47d9f5 is described below

commit e47d9f58bff017f36a476bfb705e6e5c5cc61da0
Author: Temple Zhou <db...@gmail.com>
AuthorDate: Thu Dec 13 18:34:16 2018 +0800

    KYLIN-3718 Segments in volatile range is more than designated value
---
 .../src/main/java/org/apache/kylin/metadata/model/Segments.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java
index bb68299..a406fe8 100644
--- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java
+++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java
@@ -178,7 +178,7 @@ public class Segments<T extends ISegment> extends ArrayList<T> implements Serial
         }
         Segments volatileSegs = new Segments();
         for(T seg: segs) {
-            if(seg.getTSRange().end.v + volatileRange >= latestSegEndTs) {
+            if(seg.getTSRange().end.v + volatileRange > latestSegEndTs) {
                 logger.warn("segment in volatile range: seg:" + seg.toString() +
                         "rangeStart:" + seg.getTSRange().start.v + ", rangeEnd" + seg.getTSRange().end.v);
                 volatileSegs.add(seg);