This is an automated email from the ASF dual-hosted git repository. kangkaisen pushed a commit to branch kylin-on-druid in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/kylin-on-druid by this push: new 6e79781 Update PruneIntervalsProcessor.java (#419) 6e79781 is described below commit 6e79781d825a9e6fdab837e4d928bf7ddbe0bee9 Author: 球球爸爸 <javalife0...@126.com> AuthorDate: Thu Dec 27 10:34:42 2018 +0800 Update PruneIntervalsProcessor.java (#419) --- .../apache/kylin/storage/druid/read/filter/PruneIntervalsProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/storage-druid/src/main/java/org/apache/kylin/storage/druid/read/filter/PruneIntervalsProcessor.java b/storage-druid/src/main/java/org/apache/kylin/storage/druid/read/filter/PruneIntervalsProcessor.java index d19e9cd..0b30452 100644 --- a/storage-druid/src/main/java/org/apache/kylin/storage/druid/read/filter/PruneIntervalsProcessor.java +++ b/storage-druid/src/main/java/org/apache/kylin/storage/druid/read/filter/PruneIntervalsProcessor.java @@ -110,7 +110,7 @@ public class PruneIntervalsProcessor implements Function<FilterCondition, Filter // prune segments via extracted time ranges RangeSet<Long> segmentRanges = TreeRangeSet.create(); for (CubeSegment segment : cube.getSegments(SegmentStatusEnum.READY)) { - Range<Long> segmentRange = Range.closedOpen(segment.getTSRange().start.v, segment.getTSRange().start.v); + Range<Long> segmentRange = Range.closedOpen(segment.getTSRange().start.v, segment.getTSRange().end.v); boolean containQueryRange = !result.timeRanges.subRangeSet(segmentRange).isEmpty(); if (segment.getInputRecords() > 0 && containQueryRange) { segmentRanges.add(segmentRange);