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 <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 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);