From 40ea6755ffd6f4109ddf6ffa3c1c599620f465ed Mon Sep 17 00:00:00 2001 From: Jinho Kim Date: Thu, 7 Jan 2016 13:51:18 +0900 Subject: [PATCH] TAJO-2040: Decrease the default size of max request for locality. --- .../java/org/apache/tajo/querymaster/DefaultTaskScheduler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 26dc103495..8535912d7f 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 void run() { @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()));