KYLIN-2180 minor, get owenr project in CubeDesc.init()
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/9fc8f5e2 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/9fc8f5e2 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/9fc8f5e2 Branch: refs/heads/master-hbase1.x Commit: 9fc8f5e207b5111fffaec3335efe0c8947353cfa Parents: 1a5295b Author: Li Yang <liy...@apache.org> Authored: Fri Dec 2 11:39:34 2016 +0800 Committer: Li Yang <liy...@apache.org> Committed: Fri Dec 2 11:39:34 2016 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/kylin/cube/model/CubeDesc.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/9fc8f5e2/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java ---------------------------------------------------------------------- diff --git a/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java b/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java index 327ce57..853571c 100644 --- a/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java +++ b/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java @@ -64,6 +64,9 @@ import org.apache.kylin.metadata.model.IStorageAware; import org.apache.kylin.metadata.model.JoinDesc; import org.apache.kylin.metadata.model.MeasureDesc; import org.apache.kylin.metadata.model.TblColRef; +import org.apache.kylin.metadata.project.ProjectInstance; +import org.apache.kylin.metadata.project.ProjectManager; +import org.apache.kylin.metadata.realization.RealizationType; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -519,11 +522,16 @@ public class CubeDesc extends RootPersistentEntity implements IEngineAware { public void init(KylinConfig config) { this.errors.clear(); - this.config = KylinConfigExt.createInstance(config, overrideKylinProps); checkArgument(StringUtils.isNotBlank(name), "CubeDesc name is blank"); checkArgument(StringUtils.isNotBlank(modelName), "CubeDesc(%s) has blank modelName", name); + // note CubeDesc.name == CubeInstance.name + List<ProjectInstance> ownerPrj = ProjectManager.getInstance(config).findProjects(RealizationType.CUBE, name); + logger.info("CubeDesc '" + name + "' is owned by " + ownerPrj); + + this.config = KylinConfigExt.createInstance(config, overrideKylinProps); + this.model = MetadataManager.getInstance(config).getDataModelDesc(modelName); checkNotNull(this.model, "DateModelDesc(%s) not found", modelName); @@ -823,6 +831,7 @@ public class CubeDesc extends RootPersistentEntity implements IEngineAware { return col; } + @SuppressWarnings("deprecation") private void initMeasureColumns() { if (measures == null || measures.isEmpty()) { return;
