You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2018/12/14 03:34:47 UTC
[kylin] branch 2.4.x updated: KYLIN-3718 Segments in volatile range
is more than designated value
This is an automated email from the ASF dual-hosted git repository.
shaofengshi pushed a commit to branch 2.4.x
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/2.4.x by this push:
new 5b3d650 KYLIN-3718 Segments in volatile range is more than designated value
5b3d650 is described below
commit 5b3d650623b42c0ac53f8d6a2e6af07213b8937b
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 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);