From ac20de30138db9198c4207db9e08ecefb292fed0 Mon Sep 17 00:00:00 2001 From: ycq Date: Tue, 12 Jun 2018 23:31:03 +0800 Subject: [PATCH] KYLIN-3404 The last optimized time not showing up on cube planner tab --- .../java/org/apache/kylin/job/execution/CheckpointExecutable.java | 7 ++++--- .../java/org/apache/kylin/rest/response/CubeInstanceResponse.java | 1 + 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/core-job/src/main/java/org/apache/kylin/job/execution/CheckpointExecutable.java b/core-job/src/main/java/org/apache/kylin/job/execution/CheckpointExecutable.java index c5f1c0a..779809a 100644 --- a/core-job/src/main/java/org/apache/kylin/job/execution/CheckpointExecutable.java +++ b/core-job/src/main/java/org/apache/kylin/job/execution/CheckpointExecutable.java @@ -83,9 +83,10 @@ public class CheckpointExecutable extends DefaultChainedExecutable { // Add last optimization time CubeManager cubeManager = CubeManager.getInstance(executableContext.getConfig()); CubeInstance cube = cubeManager.getCube(getCubeName()); - try{ - cube.setCuboidLastOptimized(getEndTime()); - CubeUpdate cubeUpdate = new CubeUpdate(cube); + CubeInstance copyForWrite = cube.latestCopyForWrite(); + try { + copyForWrite.setCuboidLastOptimized(getEndTime()); + CubeUpdate cubeUpdate = new CubeUpdate(copyForWrite); cubeManager.updateCube(cubeUpdate); } catch (IOException e) { logger.error("Failed to update last optimized for " + getCubeName(), e); diff --git a/server-base/src/main/java/org/apache/kylin/rest/response/CubeInstanceResponse.java b/server-base/src/main/java/org/apache/kylin/rest/response/CubeInstanceResponse.java index 19a5ef5..f6f88bd 100644 --- a/server-base/src/main/java/org/apache/kylin/rest/response/CubeInstanceResponse.java +++ b/server-base/src/main/java/org/apache/kylin/rest/response/CubeInstanceResponse.java @@ -64,6 +64,7 @@ public class CubeInstanceResponse extends CubeInstance { setSegments(cube.getSegments()); setCreateTimeUTC(cube.getCreateTimeUTC()); setLastModified(cube.getDescriptor().getLastModified()); + setCuboidLastOptimized(cube.getCuboidLastOptimized()); this.model = cube.getDescriptor().getModelName(); this.partitionDateStart = cube.getDescriptor().getPartitionDateStart(); -- 2.10.1 (Apple Git-78)