[
https://issues.apache.org/jira/browse/TAJO-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14576734#comment-14576734
]
Hudson commented on TAJO-1615:
------------------------------
SUCCESS: Integrated in Tajo-master-build #728 (See
[https://builds.apache.org/job/Tajo-master-build/728/])
TAJO-1615: Implement TaskManager. (jinho) (jhkim: rev
36da0dac7d90fa12b3d9cf11fa5b561a586e60ff)
* tajo-core/src/main/java/org/apache/tajo/worker/TaskImpl.java
* tajo-core/src/test/java/org/apache/tajo/worker/MockWorkerContext.java
* tajo-core/src/main/proto/TajoWorkerProtocol.proto
* CHANGES
*
tajo-core/src/main/java/org/apache/tajo/worker/event/ExecutionBlockStopEvent.java
* tajo-core/src/test/java/org/apache/tajo/worker/TestNodeResourceManager.java
* tajo-core/src/main/java/org/apache/tajo/worker/TajoWorkerManagerService.java
* tajo-core/src/test/java/org/apache/tajo/worker/TestNodeStatusUpdater.java
* tajo-core/src/main/java/org/apache/tajo/worker/event/TaskStartEvent.java
* tajo-core/src/test/java/org/apache/tajo/worker/MockExecutionBlock.java
* tajo-core/src/main/java/org/apache/tajo/worker/NodeResourceManager.java
* tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerStartEvent.java
*
tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceAllocateEvent.java
* tajo-core/src/main/java/org/apache/tajo/worker/LegacyTaskImpl.java
* tajo-core/src/main/java/org/apache/tajo/worker/event/NodeStatusEvent.java
* tajo-core/src/main/java/org/apache/tajo/worker/event/TaskManagerEvent.java
*
tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/PhysicalExec.java
* tajo-core/src/main/java/org/apache/tajo/worker/Task.java
* tajo-core/src/main/java/org/apache/tajo/worker/TaskManager.java
* tajo-core/src/test/java/org/apache/tajo/worker/MockNodeStatusUpdater.java
* tajo-core/src/main/java/org/apache/tajo/worker/TaskAttemptContext.java
* tajo-core/src/main/java/org/apache/tajo/worker/TaskRunner.java
* tajo-core/src/main/java/org/apache/tajo/worker/event/TaskExecutorEvent.java
* tajo-core/src/main/java/org/apache/tajo/worker/NodeStatusUpdater.java
* tajo-core/src/main/java/org/apache/tajo/util/history/HistoryWriter.java
* tajo-core/src/test/java/org/apache/tajo/querymaster/TestKillQuery.java
*
tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/HashShuffleFileWriteExec.java
* tajo-core/src/main/java/org/apache/tajo/util/TajoUncaughtExceptionHandler.java
* tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerStopEvent.java
* tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerEvent.java
* tajo-core/src/main/java/org/apache/tajo/worker/TaskRunnerHistory.java
* tajo-core/src/test/java/org/apache/tajo/worker/MockTaskManager.java
* tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceEvent.java
* tajo-core/src/test/java/org/apache/tajo/worker/MockTaskExecutor.java
* tajo-core/src/test/java/org/apache/tajo/worker/TestFetcher.java
* tajo-core/src/main/java/org/apache/tajo/worker/TaskExecutor.java
*
tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceManagerEvent.java
* tajo-core/src/test/java/org/apache/tajo/worker/TestTaskExecutor.java
* tajo-core/src/main/java/org/apache/tajo/worker/ExecutionBlockContext.java
*
tajo-core/src/main/java/org/apache/tajo/worker/event/ExecutionBlockStartEvent.java
* tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java
* tajo-core/src/test/java/org/apache/tajo/worker/TestTaskManager.java
*
tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceDeallocateEvent.java
* tajo-core/src/test/java/org/apache/tajo/worker/MockNodeResourceManager.java
* tajo-core/src/main/java/org/apache/tajo/worker/TajoWorker.java
* tajo-core/src/main/java/org/apache/tajo/worker/TaskContainer.java
* tajo-core/src/main/java/org/apache/tajo/worker/TaskRunnerManager.java
> Implement TaskManager
> ---------------------
>
> Key: TAJO-1615
> URL: https://issues.apache.org/jira/browse/TAJO-1615
> Project: Tajo
> Issue Type: Sub-task
> Components: worker
> Reporter: Jinho Kim
> Assignee: Jinho Kim
> Labels: multi-tenant, scheduler
> Fix For: 0.11.0
>
> Attachments: TAJO-1615.patch
>
>
> Currently, TaskRunner threads is created and the size is fixed when the stage
> starts. We should add dedicated task executor for reassignment.
> TaskExecutor creates thread by size of cpu-cores. It means that the maximum
> parallel task size is cpu-cores
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
