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/04/30 09:13:29 UTC
kylin git commit: KYLIN-1639 Fix typo for wrong logging of JobID
Repository: kylin
Updated Branches:
refs/heads/1.3.x 6241037e4 -> 47288d7fa
KYLIN-1639 Fix typo for wrong logging of JobID
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/47288d7f
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/47288d7f
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/47288d7f
Branch: refs/heads/1.3.x
Commit: 47288d7fad788243fc22ecaeaa4a6ea89abc45f8
Parents: 6241037
Author: lidongsjtu <li...@apache.org>
Authored: Sat Apr 30 15:13:35 2016 +0800
Committer: lidongsjtu <li...@apache.org>
Committed: Sat Apr 30 15:13:35 2016 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/job/common/MapReduceExecutable.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/47288d7f/job/src/main/java/org/apache/kylin/job/common/MapReduceExecutable.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/common/MapReduceExecutable.java b/job/src/main/java/org/apache/kylin/job/common/MapReduceExecutable.java
index cb6e76c..232a74c 100644
--- a/job/src/main/java/org/apache/kylin/job/common/MapReduceExecutable.java
+++ b/job/src/main/java/org/apache/kylin/job/common/MapReduceExecutable.java
@@ -106,7 +106,7 @@ public class MapReduceExecutable extends AbstractExecutable {
if (extra.containsKey(ExecutableConstants.MR_JOB_ID)) {
Configuration conf = HadoopUtil.getCurrentConfiguration();
job = new Cluster(conf).getJob(JobID.forName(extra.get(ExecutableConstants.MR_JOB_ID)));
- logger.info("mr_job_id:" + extra.get(ExecutableConstants.MR_JOB_ID + " resumed"));
+ logger.info("mr_job_id:" + extra.get(ExecutableConstants.MR_JOB_ID) + " resumed");
} else {
final Constructor<? extends AbstractHadoopJob> constructor = ClassUtil.forName(mapReduceJobClass, AbstractHadoopJob.class).getConstructor();
final AbstractHadoopJob hadoopJob = constructor.newInstance();