You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ka...@apache.org on 2018/12/27 02:34:46 UTC
[kylin] branch kylin-on-druid updated: Update
PruneIntervalsProcessor.java (#419)
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: 球球爸爸 <ja...@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);