You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by jh...@apache.org on 2016/01/07 07:24:31 UTC
tajo git commit: TAJO-2040: Decrease the default size of max request
for locality.
Repository: tajo
Updated Branches:
refs/heads/master 7f4422473 -> 64c31a226
TAJO-2040: Decrease the default size of max request for locality.
Closes #931
Project: http://git-wip-us.apache.org/repos/asf/tajo/repo
Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/64c31a22
Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/64c31a22
Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/64c31a22
Branch: refs/heads/master
Commit: 64c31a226339d981c17fcd9778446e702db205f5
Parents: 7f44224
Author: Jinho Kim <jh...@apache.org>
Authored: Thu Jan 7 15:23:51 2016 +0900
Committer: Jinho Kim <jh...@apache.org>
Committed: Thu Jan 7 15:23:51 2016 +0900
----------------------------------------------------------------------
CHANGES | 2 ++
.../java/org/apache/tajo/querymaster/DefaultTaskScheduler.java | 2 +-
2 files changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/64c31a22/CHANGES
----------------------------------------------------------------------
diff --git a/CHANGES b/CHANGES
index d3108dc..ffe3c6d 100644
--- a/CHANGES
+++ b/CHANGES
@@ -8,6 +8,8 @@ Release 0.12.0 - unreleased
IMPROVEMENT
+ TAJO-2040: Decrease the default size of max request for locality. (jinho)
+
TAJO-2035: Rewrite README file using Markdown format.
(Dongkyu Hwangbo via jinho)
http://git-wip-us.apache.org/repos/asf/tajo/blob/64c31a22/tajo-core/src/main/java/org/apache/tajo/querymaster/DefaultTaskScheduler.java
----------------------------------------------------------------------
diff --git a/tajo-core/src/main/java/org/apache/tajo/querymaster/DefaultTaskScheduler.java b/tajo-core/src/main/java/org/apache/tajo/querymaster/DefaultTaskScheduler.java
index 26dc103..8535912 100644
--- a/tajo-core/src/main/java/org/apache/tajo/querymaster/DefaultTaskScheduler.java
+++ b/tajo-core/src/main/java/org/apache/tajo/querymaster/DefaultTaskScheduler.java
@@ -133,7 +133,7 @@ public class DefaultTaskScheduler extends AbstractTaskScheduler {
@Override
public void start() {
LOG.info("Start TaskScheduler");
- maximumRequestContainer = tajoConf.getInt(REQUEST_MAX_NUM, stage.getContext().getWorkerMap().size() * 2);
+ maximumRequestContainer = tajoConf.getInt(REQUEST_MAX_NUM, stage.getContext().getWorkerMap().size());
if (isLeaf) {
candidateWorkers.addAll(getWorkerIds(getLeafTaskHosts()));