Repository: kylin Updated Branches: refs/heads/1.4-rc 8c0de89a6 -> c6aa81b1d
DELETE hard coding of mapred.task.timeout Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/c6aa81b1 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/c6aa81b1 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/c6aa81b1 Branch: refs/heads/1.4-rc Commit: c6aa81b1d92542e1af4f62337d2026868dada7bc Parents: 8c0de89 Author: kyotoYaho <[email protected]> Authored: Tue Jun 28 10:24:30 2016 +0800 Committer: kyotoYaho <[email protected]> Committed: Tue Jun 28 10:24:30 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/engine/mr/steps/InMemCuboidJob.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/c6aa81b1/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/InMemCuboidJob.java ---------------------------------------------------------------------- diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/InMemCuboidJob.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/InMemCuboidJob.java index d197252..0685dcf 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/InMemCuboidJob.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/InMemCuboidJob.java @@ -106,8 +106,8 @@ public class InMemCuboidJob extends AbstractHadoopJob { // set job configuration job.getConfiguration().set(BatchConstants.CFG_CUBE_NAME, cubeName); job.getConfiguration().set(BatchConstants.CFG_CUBE_SEGMENT_NAME, segmentName); - long timeout = 1000 * 60 * 60L; // 1 hour - job.getConfiguration().set("mapred.task.timeout", String.valueOf(timeout)); +// long timeout = 1000 * 60 * 60L; // 1 hour +// job.getConfiguration().set("mapred.task.timeout", String.valueOf(timeout)); // set input IMRTableInputFormat flatTableInputFormat = MRUtil.getBatchCubingInputSide(cubeSeg).getFlatTableInputFormat();
