[ 
https://issues.apache.org/jira/browse/IMPALA-4670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Michael Ho resolved IMPALA-4670.
--------------------------------
       Resolution: Fixed
    Fix Version/s: Impala 2.11.0

https://github.com/apache/incubator-impala/commit/dd4c6be8e082d4dd42e099e9a03ed23fdae9c13b

IMPALA-4670: Introduces RpcMgr class
This patch introduces a new class, RpcMgr which is the abstraction
layer around KRPC core mechanics. It provides an interface
RegisterService() for various services to register themselves.

Kudu RPC is invoked via an auto-generated interface called proxy.
This change implements an inline wrapper for KRPC client to obtain
a proxy for a particular service exported by remote server.

Last but not least, the RpcMgr will start all registered services
if FLAGS_use_krpc is true. This patch hasn't yet added any service
except for some test services in rpc-mgr-test.

This patch is based on an abandoned patch by Henry Robinson.

Testing done: a new backend test is added to exercise the code
and demonstrate the way to interact with KRPC framework.

Change-Id: I8adb10ae375d7bf945394c38a520f12d29cf7b46
Reviewed-on: http://gerrit.cloudera.org:8080/7901
Reviewed-by: Michael Ho <k...@cloudera.com>
Tested-by: Impala Public Jenkins

> Add RpcMgr to interface between Impala and KRPC library
> -------------------------------------------------------
>
>                 Key: IMPALA-4670
>                 URL: https://issues.apache.org/jira/browse/IMPALA-4670
>             Project: IMPALA
>          Issue Type: Sub-task
>          Components: Distributed Exec
>    Affects Versions: Impala 2.8.0
>            Reporter: Henry Robinson
>            Assignee: Michael Ho
>             Fix For: Impala 2.11.0
>
>
> Add the necessary abstractions to integrate KRPC into Impala's codebase. 
> Particularly, add an {{RpcMgr}} that allows:
> * acceptor threads to be started on a port
> * service (de)registration 
> * proxy construction
> This replaces {{ThriftServer}} and {{ThriftClient}} / {{ConnectionCache}} for 
> backend services.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to