Details

      Description

      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

        Issue Links

          Activity

          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user jinossy opened a pull request:

          https://github.com/apache/tajo/pull/595

          TAJO-1615: Implement TaskExecutor

          You can merge this pull request into a Git repository by running:

          $ git pull https://github.com/jinossy/tajo TAJO-1615

          Alternatively you can review and apply these changes as the patch at:

          https://github.com/apache/tajo/pull/595.patch

          To close this pull request, make a commit to your master/trunk branch
          with (at least) the following in the commit message:

          This closes #595


          commit 0d6ca33ec2d5b6f5be8bd3d78385b620548a7efb
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-15T03:03:59Z

          TAJO-1599

          commit 211f000bb8c14af81b5d77be9ae355b6d0b56cb1
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-18T07:15:14Z

          TAJO-1599

          commit 9631601b875f01e72fa4a3e74ec7c2a157d8a34f
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-18T07:15:30Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1599

          commit c0257fdc33009f26e31cbd8a1043f3bd6f7600ce
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-18T16:42:49Z

          add test cases

          commit fafd6487a56980355b3b596d392f299aad2d434f
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-18T16:43:54Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1599

          commit 24a845cdaf1467610c897e35ed6b98ece8cb7d02
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-18T17:24:21Z

          trigger CI

          commit 798c1451efacba27ac50e25baf9fef95af9a4880
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T01:51:43Z

          TAJO-1599

          commit 9b7a9f30e48e51d79ed85264a762d71836e10c66
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T01:56:06Z

          I can't rename file. maybe git bug

          commit 9b40d944e5252cd3c34350ddb2866f8a6cf60b21
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T02:06:30Z

          delete old file

          commit 4448a0bd8ecde82225ea49b72cb015d781e1a0ad
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T02:07:17Z

          add renamed file

          commit 5d75eb3d20ec9ba29d21e7f626a08dbd689e7505
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T02:09:28Z

          revert changes

          commit 097a50e738fa47e7d314d109d945ee063e758612
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T02:25:39Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1599

          commit ec57a13f0349f29135a00b02fb24c0a70006a40f
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T14:47:15Z

          change to atomic updater and update test case

          commit 3f20ce5eae6da26f66b827a82ffc18fe944529da
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T14:48:42Z

          Merge branch 'TAJO-1599' of https://github.com/jinossy/tajo into TAJO-1599

          commit 9902e57fc0b613b8a7ebad22b801ced8bdf680f4
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T15:04:33Z

          remove findbugs warnings

          commit 3543eaabba6aa2b57011e4484e9a25272d938f86
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T15:05:46Z

          TAJO-1615

          commit fb67da021a9d751cb2e9c4aa4da61d0d3b1cf512
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-19T15:06:24Z

          TAJO-1615

          commit fa9d2960a52520be2a9c02c5902d685ead093a10
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-20T04:49:36Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1599

          commit 1d33d36c917f1f1bb376225dcccf18f61568fcc9
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-20T04:59:53Z

          rename service to manager

          commit 7503871161b87400952c23ecfa081d234cbcc68b
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-20T05:03:38Z

          Merge branch 'TAJO-1599' of https://github.com/jinossy/tajo into TAJO-1615

          commit 830356411d68cebcd252cf19d207884ca282ce72
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-20T08:20:17Z

          Merge branch 'TAJO-1599' of https://github.com/jinossy/tajo into TAJO-1615

          commit ef46271d22e023b4eb52d81849e290b1b8c91dfb
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-27T02:33:26Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1615

          commit b30b82886b1141e730ba93c71c7a471f285082e8
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-27T02:33:33Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1615

          commit ebd1a53dcf2c1599a4ba346bf8422103dc49f223
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-28T05:53:39Z

          TAJO-1615

          commit ed42ddcd2a064e892ea6f11682b981d6678e415d
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-28T05:53:54Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1615

          commit 796dedeb6f9cdda87d7fd3ca8c211423d5cb29e4
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-28T15:26:24Z

          TAJO-1615

          commit b913c88699f5ba6fc13a9f1ee0b65c2b1fba68fc
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-29T08:32:09Z

          add more test case

          commit e0d22688912b906e38252678955ee912c6d86e0a
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-05-29T09:04:19Z

          Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1615

          commit 1ca09fda5a97747a79f78af9b9bc66c92a625f76
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-06-01T01:34:46Z

          TAJO-1615

          commit be992854a846ecc9f10486cb414b7132942b7237
          Author: Jinho Kim <jhkim@apache.org>
          Date: 2015-06-01T03:14:43Z

          TAJO-1615


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user jinossy opened a pull request: https://github.com/apache/tajo/pull/595 TAJO-1615 : Implement TaskExecutor You can merge this pull request into a Git repository by running: $ git pull https://github.com/jinossy/tajo TAJO-1615 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/tajo/pull/595.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #595 commit 0d6ca33ec2d5b6f5be8bd3d78385b620548a7efb Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-15T03:03:59Z TAJO-1599 commit 211f000bb8c14af81b5d77be9ae355b6d0b56cb1 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-18T07:15:14Z TAJO-1599 commit 9631601b875f01e72fa4a3e74ec7c2a157d8a34f Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-18T07:15:30Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1599 commit c0257fdc33009f26e31cbd8a1043f3bd6f7600ce Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-18T16:42:49Z add test cases commit fafd6487a56980355b3b596d392f299aad2d434f Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-18T16:43:54Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1599 commit 24a845cdaf1467610c897e35ed6b98ece8cb7d02 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-18T17:24:21Z trigger CI commit 798c1451efacba27ac50e25baf9fef95af9a4880 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T01:51:43Z TAJO-1599 commit 9b7a9f30e48e51d79ed85264a762d71836e10c66 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T01:56:06Z I can't rename file. maybe git bug commit 9b40d944e5252cd3c34350ddb2866f8a6cf60b21 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T02:06:30Z delete old file commit 4448a0bd8ecde82225ea49b72cb015d781e1a0ad Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T02:07:17Z add renamed file commit 5d75eb3d20ec9ba29d21e7f626a08dbd689e7505 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T02:09:28Z revert changes commit 097a50e738fa47e7d314d109d945ee063e758612 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T02:25:39Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1599 commit ec57a13f0349f29135a00b02fb24c0a70006a40f Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T14:47:15Z change to atomic updater and update test case commit 3f20ce5eae6da26f66b827a82ffc18fe944529da Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T14:48:42Z Merge branch ' TAJO-1599 ' of https://github.com/jinossy/tajo into TAJO-1599 commit 9902e57fc0b613b8a7ebad22b801ced8bdf680f4 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T15:04:33Z remove findbugs warnings commit 3543eaabba6aa2b57011e4484e9a25272d938f86 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T15:05:46Z TAJO-1615 commit fb67da021a9d751cb2e9c4aa4da61d0d3b1cf512 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-19T15:06:24Z TAJO-1615 commit fa9d2960a52520be2a9c02c5902d685ead093a10 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-20T04:49:36Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1599 commit 1d33d36c917f1f1bb376225dcccf18f61568fcc9 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-20T04:59:53Z rename service to manager commit 7503871161b87400952c23ecfa081d234cbcc68b Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-20T05:03:38Z Merge branch ' TAJO-1599 ' of https://github.com/jinossy/tajo into TAJO-1615 commit 830356411d68cebcd252cf19d207884ca282ce72 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-20T08:20:17Z Merge branch ' TAJO-1599 ' of https://github.com/jinossy/tajo into TAJO-1615 commit ef46271d22e023b4eb52d81849e290b1b8c91dfb Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-27T02:33:26Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1615 commit b30b82886b1141e730ba93c71c7a471f285082e8 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-27T02:33:33Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1615 commit ebd1a53dcf2c1599a4ba346bf8422103dc49f223 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-28T05:53:39Z TAJO-1615 commit ed42ddcd2a064e892ea6f11682b981d6678e415d Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-28T05:53:54Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1615 commit 796dedeb6f9cdda87d7fd3ca8c211423d5cb29e4 Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-28T15:26:24Z TAJO-1615 commit b913c88699f5ba6fc13a9f1ee0b65c2b1fba68fc Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-29T08:32:09Z add more test case commit e0d22688912b906e38252678955ee912c6d86e0a Author: Jinho Kim <jhkim@apache.org> Date: 2015-05-29T09:04:19Z Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into TAJO-1615 commit 1ca09fda5a97747a79f78af9b9bc66c92a625f76 Author: Jinho Kim <jhkim@apache.org> Date: 2015-06-01T01:34:46Z TAJO-1615 commit be992854a846ecc9f10486cb414b7132942b7237 Author: Jinho Kim <jhkim@apache.org> Date: 2015-06-01T03:14:43Z TAJO-1615
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user jinossy commented on the pull request:

          https://github.com/apache/tajo/pull/595#issuecomment-107334199

          I'll update the wiki continuously.
          https://cwiki.apache.org/confluence/display/TAJO/Tajo+Internal

          Show
          githubbot ASF GitHub Bot added a comment - Github user jinossy commented on the pull request: https://github.com/apache/tajo/pull/595#issuecomment-107334199 I'll update the wiki continuously. https://cwiki.apache.org/confluence/display/TAJO/Tajo+Internal
          Hide
          tajoqa Tajo QA added a comment -

          -1 overall. Here are the results of testing the latest attachment
          http://issues.apache.org/jira/secure/attachment/12736504/TAJO-1615.patch
          against master revision release-0.9.0-rc0-316-g03294e1.

          +1 @author. The patch does not contain any @author tags.

          +1 tests included. The patch appears to include 12 new or modified test files.

          +1 javac. The applied patch does not increase the total number of javac compiler warnings.

          +1 javadoc. The applied patch does not increase the total number of javadoc warnings.

          +1 checkstyle. The patch generated 0 code style errors.

          -1 findbugs. The patch appears to introduce 2 new Findbugs (version 2.0.3) warnings.

          +1 release audit. The applied patch does not increase the total number of release audit warnings.

          +1 core tests. The patch passed unit tests in tajo-core.

          Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/802//testReport/
          Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/802//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-core.html
          Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/802//console

          This message is automatically generated.

          Show
          tajoqa Tajo QA added a comment - -1 overall. Here are the results of testing the latest attachment http://issues.apache.org/jira/secure/attachment/12736504/TAJO-1615.patch against master revision release-0.9.0-rc0-316-g03294e1. +1 @author. The patch does not contain any @author tags. +1 tests included. The patch appears to include 12 new or modified test files. +1 javac. The applied patch does not increase the total number of javac compiler warnings. +1 javadoc. The applied patch does not increase the total number of javadoc warnings. +1 checkstyle. The patch generated 0 code style errors. -1 findbugs. The patch appears to introduce 2 new Findbugs (version 2.0.3) warnings. +1 release audit. The applied patch does not increase the total number of release audit warnings. +1 core tests. The patch passed unit tests in tajo-core. Test results: https://builds.apache.org/job/PreCommit-TAJO-Build/802//testReport/ Findbugs warnings: https://builds.apache.org/job/PreCommit-TAJO-Build/802//artifact/incubator-tajo/patchprocess/newPatchFindbugsWarningstajo-core.html Console output: https://builds.apache.org/job/PreCommit-TAJO-Build/802//console This message is automatically generated.
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user jihoonson commented on the pull request:

          https://github.com/apache/tajo/pull/595#issuecomment-109889257

          +1 looks good to me!
          Before commit, it is better if you add a TODO comment for TaskId.getTaskId() to reduce confusion.

          Show
          githubbot ASF GitHub Bot added a comment - Github user jihoonson commented on the pull request: https://github.com/apache/tajo/pull/595#issuecomment-109889257 +1 looks good to me! Before commit, it is better if you add a TODO comment for TaskId.getTaskId() to reduce confusion.
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

          https://github.com/apache/tajo/pull/595

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/tajo/pull/595
          Hide
          jhkim Jinho Kim added a comment -

          committed it.
          Thank you for the review!

          Show
          jhkim Jinho Kim added a comment - committed it. Thank you for the review!
          Hide
          hudson Hudson added a comment -

          ABORTED: Integrated in Tajo-master-CODEGEN-build #367 (See https://builds.apache.org/job/Tajo-master-CODEGEN-build/367/)
          TAJO-1615: Implement TaskManager. (jinho) (jhkim: rev 36da0dac7d90fa12b3d9cf11fa5b561a586e60ff)

          • tajo-core/src/main/java/org/apache/tajo/worker/event/TaskExecutorEvent.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerEvent.java
          • tajo-core/src/test/java/org/apache/tajo/worker/MockTaskExecutor.java
          • tajo-core/src/test/java/org/apache/tajo/worker/TestNodeResourceManager.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TajoWorker.java
          • tajo-core/src/main/proto/TajoWorkerProtocol.proto
          • tajo-core/src/main/java/org/apache/tajo/worker/event/TaskManagerEvent.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/ExecutionBlockStopEvent.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/NodeStatusEvent.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceEvent.java
          • tajo-core/src/main/java/org/apache/tajo/worker/LegacyTaskImpl.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/main/java/org/apache/tajo/util/TajoUncaughtExceptionHandler.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceDeallocateEvent.java
          • tajo-core/src/test/java/org/apache/tajo/worker/MockTaskManager.java
          • tajo-core/src/test/java/org/apache/tajo/worker/MockNodeStatusUpdater.java
          • tajo-core/src/test/java/org/apache/tajo/worker/TestFetcher.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerStartEvent.java
          • tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/HashShuffleFileWriteExec.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceAllocateEvent.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/Task.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskRunnerManager.java
          • tajo-core/src/main/java/org/apache/tajo/worker/NodeResourceManager.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskRunnerHistory.java
          • tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/PhysicalExec.java
          • tajo-core/src/test/java/org/apache/tajo/worker/MockNodeResourceManager.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TajoWorkerManagerService.java
          • CHANGES
          • tajo-core/src/main/java/org/apache/tajo/worker/event/ExecutionBlockStartEvent.java
          • tajo-core/src/test/java/org/apache/tajo/worker/TestTaskManager.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskContainer.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskManager.java
          • tajo-core/src/test/java/org/apache/tajo/querymaster/TestKillQuery.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskAttemptContext.java
          • tajo-core/src/main/java/org/apache/tajo/worker/ExecutionBlockContext.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/TaskStartEvent.java
          • tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskExecutor.java
          • tajo-core/src/test/java/org/apache/tajo/worker/MockExecutionBlock.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskImpl.java
          • tajo-core/src/main/java/org/apache/tajo/worker/TaskRunner.java
          • tajo-core/src/test/java/org/apache/tajo/worker/TestNodeStatusUpdater.java
          • tajo-core/src/test/java/org/apache/tajo/worker/MockWorkerContext.java
          • tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerStopEvent.java
          Show
          hudson Hudson added a comment - ABORTED: Integrated in Tajo-master-CODEGEN-build #367 (See https://builds.apache.org/job/Tajo-master-CODEGEN-build/367/ ) TAJO-1615 : Implement TaskManager. (jinho) (jhkim: rev 36da0dac7d90fa12b3d9cf11fa5b561a586e60ff) tajo-core/src/main/java/org/apache/tajo/worker/event/TaskExecutorEvent.java tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerEvent.java tajo-core/src/test/java/org/apache/tajo/worker/MockTaskExecutor.java tajo-core/src/test/java/org/apache/tajo/worker/TestNodeResourceManager.java tajo-core/src/main/java/org/apache/tajo/worker/TajoWorker.java tajo-core/src/main/proto/TajoWorkerProtocol.proto tajo-core/src/main/java/org/apache/tajo/worker/event/TaskManagerEvent.java tajo-core/src/main/java/org/apache/tajo/worker/event/ExecutionBlockStopEvent.java tajo-core/src/main/java/org/apache/tajo/worker/event/NodeStatusEvent.java tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceEvent.java tajo-core/src/main/java/org/apache/tajo/worker/LegacyTaskImpl.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/main/java/org/apache/tajo/util/TajoUncaughtExceptionHandler.java tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceDeallocateEvent.java tajo-core/src/test/java/org/apache/tajo/worker/MockTaskManager.java tajo-core/src/test/java/org/apache/tajo/worker/MockNodeStatusUpdater.java tajo-core/src/test/java/org/apache/tajo/worker/TestFetcher.java tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerStartEvent.java tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/HashShuffleFileWriteExec.java tajo-core/src/main/java/org/apache/tajo/worker/event/NodeResourceAllocateEvent.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/Task.java tajo-core/src/main/java/org/apache/tajo/worker/TaskRunnerManager.java tajo-core/src/main/java/org/apache/tajo/worker/NodeResourceManager.java tajo-core/src/main/java/org/apache/tajo/worker/TaskRunnerHistory.java tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/PhysicalExec.java tajo-core/src/test/java/org/apache/tajo/worker/MockNodeResourceManager.java tajo-core/src/main/java/org/apache/tajo/worker/TajoWorkerManagerService.java CHANGES tajo-core/src/main/java/org/apache/tajo/worker/event/ExecutionBlockStartEvent.java tajo-core/src/test/java/org/apache/tajo/worker/TestTaskManager.java tajo-core/src/main/java/org/apache/tajo/worker/TaskContainer.java tajo-core/src/main/java/org/apache/tajo/worker/TaskManager.java tajo-core/src/test/java/org/apache/tajo/querymaster/TestKillQuery.java tajo-core/src/main/java/org/apache/tajo/worker/TaskAttemptContext.java tajo-core/src/main/java/org/apache/tajo/worker/ExecutionBlockContext.java tajo-core/src/main/java/org/apache/tajo/worker/event/TaskStartEvent.java tajo-core/src/main/java/org/apache/tajo/master/rm/TajoResourceTracker.java tajo-core/src/main/java/org/apache/tajo/worker/TaskExecutor.java tajo-core/src/test/java/org/apache/tajo/worker/MockExecutionBlock.java tajo-core/src/main/java/org/apache/tajo/worker/TaskImpl.java tajo-core/src/main/java/org/apache/tajo/worker/TaskRunner.java tajo-core/src/test/java/org/apache/tajo/worker/TestNodeStatusUpdater.java tajo-core/src/test/java/org/apache/tajo/worker/MockWorkerContext.java tajo-core/src/main/java/org/apache/tajo/worker/event/TaskRunnerStopEvent.java
          Hide
          hudson Hudson added a comment -

          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
          Show
          hudson Hudson added a comment - 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

            People

            • Assignee:
              jhkim Jinho Kim
              Reporter:
              jhkim Jinho Kim
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development