Repository: kylin Updated Branches: refs/heads/master ac347fd1e -> 47a7cbeb9
minor add more debug log Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/47a7cbeb Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/47a7cbeb Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/47a7cbeb Branch: refs/heads/master Commit: 47a7cbeb9c2879c7301fe7c9c94cfde0d6caf4a5 Parents: ac347fd Author: Hongbin Ma <[email protected]> Authored: Tue Jul 12 14:24:45 2016 +0800 Committer: Hongbin Ma <[email protected]> Committed: Tue Jul 12 14:24:45 2016 +0800 ---------------------------------------------------------------------- .../kylin/engine/mr/steps/FactDistinctColumnsJob.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/47a7cbeb/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsJob.java ---------------------------------------------------------------------- diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsJob.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsJob.java index 4225ca9..c163b55 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsJob.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsJob.java @@ -85,7 +85,15 @@ public class FactDistinctColumnsJob extends AbstractHadoopJob { setJobClasspath(job, cube.getConfig()); - setupMapper(cube.getSegment(segmentName, SegmentStatusEnum.NEW)); + CubeSegment segment = cube.getSegment(segmentName, SegmentStatusEnum.NEW); + if (segment == null) { + logger.error("Failed to find {} in cube {}", segmentName, cube); + for (CubeSegment s : cube.getSegments()) { + logger.error(s.getName() + " with status " + s.getStatus()); + } + throw new IllegalStateException(); + } + setupMapper(segment); setupReducer(output, "true".equalsIgnoreCase(statistics_enabled) ? columnsNeedDict.size() + 1 : columnsNeedDict.size()); attachKylinPropsAndMetadata(cube, job.getConfiguration());
