This is an automated email from the ASF dual-hosted git repository. nic pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/master by this push: new 1e64c23 Fix minor bug 1e64c23 is described below commit 1e64c23c49043a426889274aacf26652d9d96d0a Author: XiaoxiangYu <hit_la...@126.com> AuthorDate: Mon Sep 30 00:31:31 2019 +0800 Fix minor bug --- .../src/main/java/org/apache/kylin/metadata/model/Segments.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) 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 0fdb2ea..e85be7c 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,15 +178,13 @@ 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) { - logger.warn("segment in volatile range: seg: " + seg.toString() + - ", rangeStart:" + seg.getTSRange().start.v + ", rangeEnd" + seg.getTSRange().end.v); + if (seg.getTSRange().end.v + volatileRange > latestSegEndTs) { + logger.warn("Segment in volatile range, seg: {}, rangeStart:{}, rangeEnd {}.", seg, + seg.getTSRange().start.v, seg.getTSRange().end.v); volatileSegs.add(seg); } } - segs.removeAll(volatileSegs); - } public SegmentRange autoMergeCubeSegments(boolean needAutoMerge, String cubeName, long[] timeRanges, long volatileRange) throws IOException {