You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2015/11/05 02:54:20 UTC
[06/31] incubator-kylin git commit: KYLIN-953 Again - Let
MapReduceExecutable pick up patched hadoop config
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/5fec41f9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/5fec41f9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/5fec41f9
Branch: refs/heads/KYLIN-1112
Commit: 5fec41f9dc78ac7ea3594d14666d143fcf2f619d
Parents: f79d7c5
Author: Li, Yang <ya...@ebay.com>
Authored: Mon Nov 2 15:22:42 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Thu Nov 5 09:53:16 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/5fec41f9/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 ebb3900..46557c8 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
@@ -109,6 +109,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);