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 <dba...@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);