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/eb4cec69 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/eb4cec69 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/eb4cec69 Branch: refs/heads/1.5.x-HBase1.x Commit: eb4cec69fb877f5b9f0b1de450eae296f22843ef Parents: 2fc5827 Author: lidongsjtu <lid...@apache.org> Authored: Sat Apr 30 14:35:08 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Sat Apr 30 14:35:08 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/engine/mr/common/MapReduceExecutable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/eb4cec69/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java ---------------------------------------------------------------------- diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java index 19d888c..54459d7 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java @@ -104,7 +104,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();
