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/02 08:22:11 UTC
incubator-kylin git commit: KYLIN-953 Again - Let MapReduceExecutable
pick up patched hadoop config
Repository: incubator-kylin
Updated Branches:
refs/heads/1.x-staging 2c1c19510 -> 3e2ccfbe3
KYLIN-953 Again - Let MapReduceExecutable pick up patched hadoop config
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/3e2ccfbe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/3e2ccfbe
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/3e2ccfbe
Branch: refs/heads/1.x-staging
Commit: 3e2ccfbe35c1477be276b7a17bb021fd6e08ff9c
Parents: 2c1c195
Author: Li, Yang <ya...@ebay.com>
Authored: Mon Nov 2 15:21:58 2015 +0800
Committer: Li, Yang <ya...@ebay.com>
Committed: Mon Nov 2 15:21:58 2015 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/job/common/MapReduceExecutable.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/3e2ccfbe/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 2220884..2d2cfe6 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
@@ -110,6 +110,7 @@ public class MapReduceExecutable extends AbstractExecutable {
} else {
final Constructor<? extends AbstractHadoopJob> constructor = ClassUtil.forName(mapReduceJobClass, AbstractHadoopJob.class).getConstructor();
final AbstractHadoopJob hadoopJob = constructor.newInstance();
+ hadoopJob.setConf(HadoopUtil.getCurrentConfiguration());
hadoopJob.setAsync(true); // so the ToolRunner.run() returns right away
logger.info("parameters of the MapReduceExecutable:");
logger.info(params);