Repository: kylin Updated Branches: refs/heads/master 4fae26781 -> 4c636b8a3
KYLIN-1726 keepRetention should exclude the segments which hasnât update dateRangeEnd Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/4c636b8a Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/4c636b8a Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/4c636b8a Branch: refs/heads/master Commit: 4c636b8a3a4df90d27f72391605b5500800a95a4 Parents: 4fae267 Author: shaofengshi <shaofeng...@apache.org> Authored: Sat Oct 8 11:15:49 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Sat Oct 8 11:15:49 2016 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/kylin/rest/service/CubeService.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/4c636b8a/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java ---------------------------------------------------------------------- diff --git a/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java b/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java index ea32ef7..99e54b9 100644 --- a/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java +++ b/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java @@ -612,8 +612,11 @@ public class CubeService extends BasicService { long tail = readySegs.get(readySegs.size() - 1).getDateRangeEnd(); long head = tail - desc.getRetentionRange(); for (CubeSegment seg : readySegs) { - if (seg.getDateRangeEnd() <= head) - toRemoveSegs.add(seg); + if (seg.getDateRangeEnd() > 0) { // for streaming cube its initial value is 0 + if (seg.getDateRangeEnd() <= head) { + toRemoveSegs.add(seg); + } + } } if (toRemoveSegs.size() > 0) {
