clear cache in CubeMetaIngester Signed-off-by: lidongsjtu <lid...@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/KYLIN-1971 Commit: c49eb9446514ba77b946ce83be59c2bd272ba3f7 Parents: 100487f Author: kangkaisen <kangkai...@live.com> Authored: Thu Oct 13 17:46:17 2016 +0800 Committer: lidongsjtu <lid...@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); }
