You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2016/07/12 06:24:59 UTC
kylin git commit: minor add more debug log
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 <ma...@apache.org>
Authored: Tue Jul 12 14:24:45 2016 +0800
Committer: Hongbin Ma <ma...@apache.org>
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());