You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/04/05 04:00:43 UTC
kylin git commit: KYLIN-1323 update BuildCubeWithEngine for sharding
storage
Repository: kylin
Updated Branches:
refs/heads/KYLIN-1323 0a29abdd7 -> c766b300e
KYLIN-1323 update BuildCubeWithEngine for sharding storage
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/c766b300
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c766b300
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c766b300
Branch: refs/heads/KYLIN-1323
Commit: c766b300e244c9a21e2cc8579dd2a029db654f9f
Parents: 0a29abd
Author: shaofengshi <sh...@apache.org>
Authored: Tue Apr 5 10:00:26 2016 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Tue Apr 5 10:00:26 2016 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/provision/BuildCubeWithEngine.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/c766b300/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java
----------------------------------------------------------------------
diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java
index 293e620..78053ad 100644
--- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java
+++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java
@@ -60,6 +60,7 @@ import org.apache.kylin.job.execution.ExecutableState;
import org.apache.kylin.job.impl.threadpool.DefaultScheduler;
import org.apache.kylin.job.manager.ExecutableManager;
import org.apache.kylin.metadata.model.IEngineAware;
+import org.apache.kylin.metadata.model.IStorageAware;
import org.apache.kylin.storage.hbase.util.HBaseRegionSizeCalculator;
import org.apache.kylin.storage.hbase.util.StorageCleanupJob;
import org.apache.kylin.storage.hbase.util.ZookeeperJobLock;
@@ -353,7 +354,10 @@ public class BuildCubeWithEngine {
DefaultChainedExecutable job = EngineFactory.createBatchCubingJob(segment, "TEST");
jobService.addJob(job);
waitForJob(job.getId());
- checkHFilesInHBase(segment);
+ if (segment.getCubeDesc().getEngineType() == IEngineAware.ID_MR_V1
+ || segment.getCubeDesc().getStorageType() == IStorageAware.ID_SHARDED_HBASE) {
+ checkHFilesInHBase(segment);
+ }
return job.getId();
}