hadoop-yarn-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Raju Bairishetti (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (YARN-3695) EOFException shouldn't be retry forever in RMProxy
Date Thu, 21 May 2015 18:25:18 GMT

    [ https://issues.apache.org/jira/browse/YARN-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554806#comment-14554806
] 

Raju Bairishetti commented on YARN-3695:
----------------------------------------

[~rohithsharma] [~djp] [~devraj.jaiman] Seems I forgot to fix retry policy FOREVER in ServerProxy
as part of [YARN-3646|https://issues.apache.org/jira/browse/YARN-3646]

ServerProxy.java
{code}
    if (maxWaitTime == -1) {
      // wait forever.
      return RetryPolicies.RETRY_FOREVER;
    }

   ...

    Map<Class<? extends Exception>, RetryPolicy> exceptionToPolicyMap =
        new HashMap<Class<? extends Exception>, RetryPolicy>();
    exceptionToPolicyMap.put(EOFException.class, retryPolicy);
    exceptionToPolicyMap.put(ConnectException.class, retryPolicy);
    ...
{code}

> EOFException shouldn't be retry forever in RMProxy
> --------------------------------------------------
>
>                 Key: YARN-3695
>                 URL: https://issues.apache.org/jira/browse/YARN-3695
>             Project: Hadoop YARN
>          Issue Type: Bug
>            Reporter: Junping Du
>
> YARN-3646 fix the retry forever policy that it only applies on limited exceptions rather
than all exceptions. Here, we may want to review these exceptions. At least, exception EOFException
shouldn't retry forever.
> {code}
>     exceptionToPolicyMap.put(EOFException.class, retryPolicy);
>     exceptionToPolicyMap.put(ConnectException.class, retryPolicy);
>     exceptionToPolicyMap.put(NoRouteToHostException.class, retryPolicy);
>     exceptionToPolicyMap.put(UnknownHostException.class, retryPolicy);
>     exceptionToPolicyMap.put(ConnectTimeoutException.class, retryPolicy);
>     exceptionToPolicyMap.put(RetriableException.class, retryPolicy);
>     exceptionToPolicyMap.put(SocketException.class, retryPolicy);
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message