Repository: kylin Updated Branches: refs/heads/yang-m1 3a8a83b2a -> c17bb7366
KYLIN-1597 consider clock gap between query server and region server Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/c17bb736 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c17bb736 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c17bb736 Branch: refs/heads/yang-m1 Commit: c17bb7366f242834d1cb89091205da80357c8021 Parents: 3a8a83b Author: Hongbin Ma <mahong...@apache.org> Authored: Tue Apr 12 14:17:56 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Tue Apr 12 14:17:56 2016 +0800 ---------------------------------------------------------------------- .../hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/c17bb736/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java index 9dfc607..753e9d3 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java @@ -216,7 +216,7 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement } final MutableBoolean normalComplete = new MutableBoolean(true); - final long startTime = request.getStartTime(); + final long startTime = this.serviceStartTime;//request.getStartTime(); final long timeout = (long) (request.getTimeout() * 0.95); InnerScannerAsIterator cellListIterator = new InnerScannerAsIterator(innerScanner, normalComplete, startTime, timeout);
