[kylin] 02/02: 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 master
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit f031005e4bd61dc6340c221d9fcbc16fa2024777
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 6c4c9a3..d66f899 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);