[kylin] branch kylin-on-druid updated: Update PruneIntervalsProcessor.java (#419)

[kangkaisen]

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);