Repository: tajo Updated Branches: refs/heads/master 7603a3d4c -> 1ab39706e
TAJO-986: Task scheduler gets incorrect task size. (Mai Hai Thanh via jihoon) Project: http://git-wip-us.apache.org/repos/asf/tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/1ab39706 Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/1ab39706 Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/1ab39706 Branch: refs/heads/master Commit: 1ab39706ec3fafe4edeef857d49db8dcace9c2d6 Parents: 7603a3d Author: Jihoon Son <[email protected]> Authored: Wed Aug 27 20:12:22 2014 +0900 Committer: Jihoon Son <[email protected]> Committed: Wed Aug 27 20:12:22 2014 +0900 ---------------------------------------------------------------------- CHANGES | 2 ++ .../src/main/java/org/apache/tajo/master/querymaster/SubQuery.java | 1 - 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/1ab39706/CHANGES ---------------------------------------------------------------------- diff --git a/CHANGES b/CHANGES index 2b5f149..77c53d5 100644 --- a/CHANGES +++ b/CHANGES @@ -127,6 +127,8 @@ Release 0.9.0 - unreleased BUG FIXES + TAJO-986: Task scheduler gets incorrect task size. (Mai Hai Thanh via jihoon) + TAJO-873: Query status is still RUNNING after session expired. (Hyoungjun Kim, jinho) http://git-wip-us.apache.org/repos/asf/tajo/blob/1ab39706/tajo-core/src/main/java/org/apache/tajo/master/querymaster/SubQuery.java ---------------------------------------------------------------------- diff --git a/tajo-core/src/main/java/org/apache/tajo/master/querymaster/SubQuery.java b/tajo-core/src/main/java/org/apache/tajo/master/querymaster/SubQuery.java index 87da175..9aec9ba 100644 --- a/tajo-core/src/main/java/org/apache/tajo/master/querymaster/SubQuery.java +++ b/tajo-core/src/main/java/org/apache/tajo/master/querymaster/SubQuery.java @@ -962,7 +962,6 @@ public class SubQuery implements EventHandler<SubQueryEvent> { if (subQuery.getTaskScheduler() instanceof DefaultTaskScheduler) { //Leaf task of DefaultTaskScheduler should be fragment size // EstimatedTaskNum determined number of initial container - subQuery.schedulerContext.setTaskSize(fragments.size()); subQuery.schedulerContext.setEstimatedTaskNum(fragments.size()); } else { TajoConf conf = subQuery.context.getConf();
