You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2016/08/18 15:15:41 UTC
kylin git commit: KYLIN-1936 fix CI
Repository: kylin
Updated Branches:
refs/heads/master 9629fa8fb -> 6c88139d4
KYLIN-1936 fix CI
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/6c88139d
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/6c88139d
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/6c88139d
Branch: refs/heads/master
Commit: 6c88139d4c91c86a916846d0ac0e4f5ce106f09a
Parents: 9629fa8
Author: Hongbin Ma <ma...@apache.org>
Authored: Thu Aug 18 23:09:32 2016 +0800
Committer: Hongbin Ma <ma...@apache.org>
Committed: Thu Aug 18 23:09:32 2016 +0800
----------------------------------------------------------------------
.../org/apache/kylin/storage/gtrecord/CubeSegmentScanner.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/6c88139d/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/CubeSegmentScanner.java
----------------------------------------------------------------------
diff --git a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/CubeSegmentScanner.java b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/CubeSegmentScanner.java
index 1a2bae3..4365ee2 100644
--- a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/CubeSegmentScanner.java
+++ b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/CubeSegmentScanner.java
@@ -72,7 +72,10 @@ public class CubeSegmentScanner implements IGTScanner {
scanRequest.setAllowStorageAggregation(context.isNeedStorageAggregation());
scanRequest.setAggCacheMemThreshold(cubeSeg.getCubeInstance().getConfig().getQueryCoprocessorMemGB());
scanRequest.setStorageScanRowNumThreshold(context.getThreshold());//TODO: devide by shard number?
- scanRequest.setStoragePushDownLimit(context.getStoragePushDownLimit());
+
+ if (cubeSeg.getCubeDesc().supportsLimitPushDown()) {
+ scanRequest.setStoragePushDownLimit(context.getStoragePushDownLimit());
+ }
}
scanner = new ScannerWorker(cubeSeg, cuboid, scanRequest, gtStorage);
}