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 2015/11/03 07:56:04 UTC
incubator-kylin git commit: minor,
fix NPE in CubingJob.formatNotifications()
Repository: incubator-kylin
Updated Branches:
refs/heads/1.x-staging bbb89f453 -> 2de3bf85c
minor, fix NPE in CubingJob.formatNotifications()
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/2de3bf85
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/2de3bf85
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/2de3bf85
Branch: refs/heads/1.x-staging
Commit: 2de3bf85cc8d63d25a12cf0df3b1ff932f1f47a7
Parents: bbb89f4
Author: Li, Yang <ya...@ebay.com>
Authored: Tue Nov 3 14:55:54 2015 +0800
Committer: Li, Yang <ya...@ebay.com>
Committed: Tue Nov 3 14:55:54 2015 +0800
----------------------------------------------------------------------
job/src/main/java/org/apache/kylin/job/cube/CubingJob.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/2de3bf85/job/src/main/java/org/apache/kylin/job/cube/CubingJob.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/cube/CubingJob.java b/job/src/main/java/org/apache/kylin/job/cube/CubingJob.java
index 760a6c3..182196c 100644
--- a/job/src/main/java/org/apache/kylin/job/cube/CubingJob.java
+++ b/job/src/main/java/org/apache/kylin/job/cube/CubingJob.java
@@ -87,7 +87,7 @@ public class CubingJob extends DefaultChainedExecutable {
content = content.replaceAll("\\$\\{job_name\\}", getName());
content = content.replaceAll("\\$\\{result\\}", state.toString());
content = content.replaceAll("\\$\\{cube_name\\}", getCubeName());
- content = content.replaceAll("\\$\\{source_records_count\\}", getSourceRecordCount());
+ content = content.replaceAll("\\$\\{source_records_count\\}", StringUtil.noBlank(getSourceRecordCount(), "0"));
content = content.replaceAll("\\$\\{start_time\\}", new Date(getStartTime()).toString());
content = content.replaceAll("\\$\\{duration\\}", getDuration() / 60000 + "mins");
content = content.replaceAll("\\$\\{mr_waiting\\}", getMapReduceWaitTime() / 60000 + "mins");