hadoop-mapreduce-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sandy Ryza (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (MAPREDUCE-5707) JobClient does not allow to setting RPC timeout for communications with JT/RM
Date Thu, 09 Jan 2014 00:54:51 GMT

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

Sandy Ryza updated MAPREDUCE-5707:
----------------------------------

    Affects Version/s:     (was: 0.20.2)
                       1.2.1

> JobClient does not allow to setting RPC timeout for communications with JT/RM
> -----------------------------------------------------------------------------
>
>                 Key: MAPREDUCE-5707
>                 URL: https://issues.apache.org/jira/browse/MAPREDUCE-5707
>             Project: Hadoop Map/Reduce
>          Issue Type: Bug
>          Components: client
>    Affects Versions: 1.2.1, 2.2.0
>            Reporter: Gilad Wolff
>
> The ApplicationClientProtocolPBClientImpl c'tor (and the JobClient 0.20.2 c'tor as well)
creates an rpc proxy that eventually uses '0' as the rpcTimeout:
> {code}
>   public ApplicationClientProtocolPBClientImpl(long clientVersion,
>       InetSocketAddress addr, Configuration conf) throws IOException {
>     RPC.setProtocolEngine(conf, ApplicationClientProtocolPB.class,
>       ProtobufRpcEngine.class);
>     proxy = RPC.getProxy(ApplicationClientProtocolPB.class, clientVersion, addr, conf);
>   }
> {code}
> which leads to this call in RPC:
> {code}
>   public static <T> ProtocolProxy<T> getProtocolProxy(Class<T> protocol,
>                                 long clientVersion,
>                                 InetSocketAddress addr,
>                                 UserGroupInformation ticket,
>                                 Configuration conf,
>                                 SocketFactory factory) throws IOException {
>     return getProtocolProxy(
>         protocol, clientVersion, addr, ticket, conf, factory, 0, null);
> {code}
> (the '0' above is the rpc timeout).
> Clients should be able to specify the rpc timeout.



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)

Mime
View raw message