[
https://issues.apache.org/jira/browse/TAJO-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13902924#comment-13902924
]
Hudson commented on TAJO-598:
-----------------------------
SUCCESS: Integrated in Tajo-master-build #65 (See
[https://builds.apache.org/job/Tajo-master-build/65/])
TAJO-598: Refactoring Tajo RPC. (jinho) (jinossy:
https://git-wip-us.apache.org/repos/asf?p=incubator-tajo.git&a=commit&h=e2a7dffdb652c77dd35a917134cef15b3d54d274)
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/worker/TajoWorker.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/HashLeftOuterJoinExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/querymaster/QueryMasterTask.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/BSTIndexScanExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/worker/TajoWorkerManagerService.java
* tajo-rpc/src/main/java/org/apache/tajo/rpc/AsyncRpcServer.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/ExternalSortExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/YarnContainerProxy.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/UnaryPhysicalExec.java
*
tajo-catalog/tajo-catalog-server/src/main/java/org/apache/tajo/catalog/CatalogServer.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/BinaryPhysicalExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/util/metrics/reporter/TajoMetricsScheduledReporter.java
* tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/worker/Fetcher.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/worker/TaskRunner.java
* tajo-rpc/src/test/java/org/apache/tajo/rpc/TestBlockingRpc.java
* tajo-rpc/src/main/java/org/apache/tajo/rpc/AsyncRpcClient.java
* tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/benchmark/TPCH.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/TajoMasterService.java
* tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/worker/Task.java
*
tajo-core/tajo-core-backend/src/test/java/org/apache/tajo/master/TestGlobalPlanner.java
* tajo-rpc/src/main/java/org/apache/tajo/rpc/RpcConnectionPool.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/LazyTaskScheduler.java
* tajo-rpc/src/main/java/org/apache/tajo/rpc/RpcChannelFactory.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/querymaster/QueryMasterManagerService.java
* tajo-client/src/main/java/org/apache/tajo/client/TajoClient.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/querymaster/QueryInProgress.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/StoreTableExec.java
*
tajo-core/tajo-core-backend/src/test/java/org/apache/tajo/engine/eval/TestEvalTreeUtil.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/BNLJoinExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/RangeShuffleFileWriteExec.java
* CHANGES.txt
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/MergeJoinExec.java
*
tajo-core/tajo-core-backend/src/test/java/org/apache/tajo/worker/TestFetcher.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/MergeFullOuterJoinExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/TajoMasterClientService.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/util/metrics/reporter/MetricsFileScheduledReporter.java
* tajo-rpc/src/main/java/org/apache/tajo/rpc/NettyServerBase.java
* tajo-rpc/src/test/java/org/apache/tajo/rpc/TestAsyncRpc.java
* tajo-rpc/src/main/java/org/apache/tajo/rpc/BlockingRpcClient.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/YarnTaskRunnerLauncherImpl.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/querymaster/QueryMaster.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/benchmark/SimpleQuery.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/worker/TajoWorkerClientService.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/HashShuffleFileWriteExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/HashAggregateExec.java
* tajo-common/src/main/java/org/apache/tajo/conf/TajoConf.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/AggregationExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/TajoContainerProxy.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/RightOuterMergeJoinExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/rm/YarnTajoResourceManager.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/TajoMaster.java
*
tajo-core/tajo-core-backend/src/test/java/org/apache/tajo/engine/eval/TestEvalTree.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/HashJoinExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/DefaultTaskScheduler.java
*
tajo-core/tajo-core-pullserver/src/main/java/org/apache/tajo/pullserver/TajoPullServerService.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/master/rm/TajoWorkerResourceManager.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/worker/TajoResourceAllocator.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/SeqScanExec.java
* tajo-rpc/src/main/java/org/apache/tajo/rpc/NettyClientBase.java
* tajo-rpc/src/main/java/org/apache/tajo/rpc/BlockingRpcServer.java
* tajo-client/src/main/java/org/apache/tajo/cli/TajoCli.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/HashFullOuterJoinExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/ProjectionExec.java
*
tajo-core/tajo-core-backend/src/main/java/org/apache/tajo/engine/planner/physical/MemSortExec.java
> Refactoring Tajo RPC
> --------------------
>
> Key: TAJO-598
> URL: https://issues.apache.org/jira/browse/TAJO-598
> Project: Tajo
> Issue Type: Improvement
> Components: rpc
> Affects Versions: 0.8-incubating
> Reporter: Jinho Kim
> Assignee: Jinho Kim
> Fix For: 0.8-incubating
>
> Attachments: TAJO-598.patch, TAJO-598_20140214_20:18:12.patch
>
>
> In the current implementation, all client rpc use same channel pool.
> It can cause a channel closed exception. we need both shared pool and new
> pool.
> In details,
> * Fix the TajoAsyncDispatcher hang
> * Fix the Fetcher timeout
> * Fix the TaskRunner thread leak
> * Fix the client rpc reconnecting
> * Fix the unittest failure(No available resources)
> * Improve RPC thread sharing
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
