From 5f13ed9c4289177cafc1defdd4329a1060dd1115 Mon Sep 17 00:00:00 2001 From: chitin Date: Tue, 30 Oct 2018 11:56:17 +0800 Subject: [PATCH] KYLIN-3649 --- .../java/org/apache/kylin/rest/service/CubeService.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java b/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java index d4ff9704a..96d60c71f 100644 --- a/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java +++ b/server-base/src/main/java/org/apache/kylin/rest/service/CubeService.java @@ -6,9 +6,9 @@ * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -53,12 +53,13 @@ import org.apache.kylin.job.execution.ExecutableState; import org.apache.kylin.measure.percentile.PercentileMeasureType; import org.apache.kylin.metadata.cachesync.Broadcaster; import org.apache.kylin.metadata.draft.Draft; -import org.apache.kylin.metadata.model.DataModelDesc; -import org.apache.kylin.metadata.model.FunctionDesc; -import org.apache.kylin.metadata.model.MeasureDesc; +import org.apache.kylin.metadata.model.IStorageAware; import org.apache.kylin.metadata.model.SegmentRange; import org.apache.kylin.metadata.model.SegmentStatusEnum; import org.apache.kylin.metadata.model.TableDesc; +import org.apache.kylin.metadata.model.DataModelDesc; +import org.apache.kylin.metadata.model.MeasureDesc; +import org.apache.kylin.metadata.model.FunctionDesc; import org.apache.kylin.metadata.project.ProjectInstance; import org.apache.kylin.metadata.project.ProjectManager; import org.apache.kylin.metadata.project.RealizationEntry; @@ -471,7 +472,8 @@ public class CubeService extends BasicService implements InitializingBean { } hr = new HBaseResponse(); - if ("hbase".equals(getConfig().getMetadataUrl().getScheme())) { + CubeInstance cube = CubeManager.getInstance(getConfig()).getCube(cubeName); + if (cube.getStorageType() == IStorageAware.ID_HBASE || cube.getStorageType() == IStorageAware.ID_SHARDED_HBASE) { try { logger.debug("Loading HTable info " + cubeName + ", " + tableName); -- 2.14.1