KYLIN-1726 segment status may have been updated while job status wasn't 
committed


Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/726b0ec9
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/726b0ec9
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/726b0ec9

Branch: refs/heads/master-cdh5.7
Commit: 726b0ec93f9f3b1b5da3520be385d6a2047d32c6
Parents: dc969cd
Author: shaofengshi <shaofeng...@apache.org>
Authored: Mon Oct 10 17:55:19 2016 +0800
Committer: shaofengshi <shaofeng...@apache.org>
Committed: Mon Oct 10 17:55:43 2016 +0800

----------------------------------------------------------------------
 core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/726b0ec9/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java
----------------------------------------------------------------------
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 269b324..c558c6d 100644
--- a/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java
+++ b/core-cube/src/main/java/org/apache/kylin/cube/CubeManager.java
@@ -836,8 +836,9 @@ public class CubeManager implements IRealizationProvider {
         if (StringUtils.isBlank(newSegment.getLastBuildJobID()))
             throw new IllegalStateException("For cube " + cube + ", segment " 
+ newSegment + " missing LastBuildJobID");
 
-        if (isReady(newSegment) == true)
-            throw new IllegalStateException("For cube " + cube + ", segment " 
+ newSegment + " state should be NEW but is READY");
+        if (isReady(newSegment) == true) {
+            logger.warn("For cube " + cube + ", segment " + newSegment + " 
state should be NEW but is READY");
+        }
 
         List<CubeSegment> tobe = calculateToBeSegments(cube, newSegment);
 

Reply via email to