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 03:01:57 UTC
[10/50] [abbrv] kylin git commit: KYLIN-1726 segment status may have
been updated while job status wasn't committed
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-hbase1.x
Commit: 726b0ec93f9f3b1b5da3520be385d6a2047d32c6
Parents: dc969cd
Author: shaofengshi <sh...@apache.org>
Authored: Mon Oct 10 17:55:19 2016 +0800
Committer: shaofengshi <sh...@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);