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 {
