You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2016/10/19 13:31:25 UTC
kylin git commit: clear cache in CubeMetaIngester
Repository: kylin
Updated Branches:
refs/heads/master 100487fc2 -> c49eb9446
clear cache in CubeMetaIngester
Signed-off-by: lidongsjtu <li...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/c49eb944
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c49eb944
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c49eb944
Branch: refs/heads/master
Commit: c49eb9446514ba77b946ce83be59c2bd272ba3f7
Parents: 100487f
Author: kangkaisen <ka...@live.com>
Authored: Thu Oct 13 17:46:17 2016 +0800
Committer: lidongsjtu <li...@apache.org>
Committed: Wed Oct 19 21:27:47 2016 +0800
----------------------------------------------------------------------
tool/src/main/java/org/apache/kylin/tool/CubeMetaIngester.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/c49eb944/tool/src/main/java/org/apache/kylin/tool/CubeMetaIngester.java
----------------------------------------------------------------------
diff --git a/tool/src/main/java/org/apache/kylin/tool/CubeMetaIngester.java b/tool/src/main/java/org/apache/kylin/tool/CubeMetaIngester.java
index 7313d80..363c407 100644
--- a/tool/src/main/java/org/apache/kylin/tool/CubeMetaIngester.java
+++ b/tool/src/main/java/org/apache/kylin/tool/CubeMetaIngester.java
@@ -132,11 +132,16 @@ public class CubeMetaIngester extends AbstractApplication {
checkAndMark(srcMetadataManager, srcHybridManager, srcCubeManager, srcCubeDescManager);
ResourceTool.copy(srcConfig, kylinConfig, Lists.newArrayList(requiredResources));
+ //clear the cache
+ metadataManager.reload();
+
for (TableDesc tableDesc : srcMetadataManager.listAllTables()) {
+ logger.info("add " + tableDesc + " to " + targetProjectName);
projectManager.addTableDescToProject(Lists.newArrayList(tableDesc.getIdentity()).toArray(new String[0]), targetProjectName);
}
for (CubeInstance cube : srcCubeManager.listAllCubes()) {
+ logger.info("add " + cube + " to " + targetProjectName);
projectManager.updateModelToProject(cube.getDataModelDesc().getName(), targetProjectName);
projectManager.moveRealizationToProject(RealizationType.CUBE, cube.getName(), targetProjectName, null);
}