Repository: kylin Updated Branches: refs/heads/2.0.x-hbase0.98 820616808 -> 39782f68e (forced update)
add check: DeployCoprocessorCLI should ensure the cube is using HBase as storage Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/bcfab74a Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/bcfab74a Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/bcfab74a Branch: refs/heads/2.0.x-hbase0.98 Commit: bcfab74a9ed486ec73c163086a8120a5722ffce4 Parents: 674410f Author: shaofengshi <shaofeng...@apache.org> Authored: Tue Apr 18 10:39:16 2017 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Tue Apr 18 13:07:23 2017 +0800 ---------------------------------------------------------------------- .../kylin/storage/hbase/util/DeployCoprocessorCLI.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/bcfab74a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java index d51b71e..c437e66 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java @@ -53,6 +53,7 @@ import org.apache.kylin.common.util.Bytes; import org.apache.kylin.cube.CubeInstance; import org.apache.kylin.cube.CubeManager; import org.apache.kylin.cube.CubeSegment; +import org.apache.kylin.metadata.model.IStorageAware; import org.apache.kylin.metadata.model.SegmentStatusEnum; import org.apache.kylin.metadata.project.ProjectInstance; import org.apache.kylin.metadata.project.ProjectManager; @@ -465,11 +466,13 @@ public class DeployCoprocessorCLI { ArrayList<String> result = new ArrayList<String>(); for (CubeInstance cube : cubeMgr.listAllCubes()) { - for (CubeSegment seg : cube.getSegments(SegmentStatusEnum.READY)) { - String tableName = seg.getStorageLocationIdentifier(); - if (StringUtils.isBlank(tableName) == false) { - result.add(tableName); - System.out.println("added new table: " + tableName); + if (cube.getStorageType() == IStorageAware.ID_HBASE || cube.getStorageType() == IStorageAware.ID_SHARDED_HBASE) { + for (CubeSegment seg : cube.getSegments(SegmentStatusEnum.READY)) { + String tableName = seg.getStorageLocationIdentifier(); + if (StringUtils.isBlank(tableName) == false) { + result.add(tableName); + System.out.println("added new table: " + tableName); + } } } }
