This is an automated email from the ASF dual-hosted git repository. shaofengshi pushed a commit to branch 2.5.x in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/2.5.x by this push: new ded1813 KYLIN-3366 Configure automatic enabling of cubes after a build process ded1813 is described below commit ded181304846a52452ce1bc3c597611d167a7eb0 Author: Zhong <nju_y...@apache.org> AuthorDate: Fri May 4 16:21:05 2018 +0800 KYLIN-3366 Configure automatic enabling of cubes after a build process Signed-off-by: shaofengshi <shaofeng...@apache.org> --- .../src/main/java/org/apache/kylin/common/KylinConfigBase.java | 4 ++++ core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java | 9 +++++++-- 2 files changed, 11 insertions(+), 2 deletions(-) diff --git a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java index 1850d20..79750e0 100644 --- a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java +++ b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java @@ -717,6 +717,10 @@ abstract public class KylinConfigBase implements Serializable { return Integer.parseInt(this.getOptional("kylin.job.metadata-persist-retry", "5")); } + public boolean isJobAutoReadyCubeEnabled() { + return Boolean.parseBoolean(getOptional("kylin.job.cube-auto-ready-enabled", "true")); + } + // ============================================================================ // SOURCE.HIVE // ============================================================================ diff --git a/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java b/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java index 23dcaf3..2a56941 100755 --- a/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java +++ b/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java @@ -894,7 +894,10 @@ public class CubeManager implements IRealizationProvider { CubeUpdate update = new CubeUpdate(cubeCopy); update.setToRemoveSegs(toRemoveSegs.toArray(new CubeSegment[toRemoveSegs.size()])) - .setToUpdateSegs(newSegCopy).setStatus(RealizationStatusEnum.READY); + .setToUpdateSegs(newSegCopy); + if (cube.getConfig().isJobAutoReadyCubeEnabled()) { + update.setStatus(RealizationStatusEnum.READY); + } updateCube(update); } @@ -944,9 +947,11 @@ public class CubeManager implements IRealizationProvider { CubeUpdate update = new CubeUpdate(cubeCopy); update.setToRemoveSegs(originalSegments) // .setToUpdateSegs(optSegCopy) // - .setStatus(RealizationStatusEnum.READY) // .setCuboids(recommendCuboids) // .setCuboidsRecommend(Sets.<Long> newHashSet()); + if (cube.getConfig().isJobAutoReadyCubeEnabled()) { + update.setStatus(RealizationStatusEnum.READY); + } updateCube(update); }