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

xuzq commented on HDFS-14937:
-----------------------------

Thanks [~xkrogen] [~vagarychen] for the comment.

RetryInvocationHandler use Thread.currentThread().isInterrupted() to check 
Interrupted, so I keep it. 
{code:java}
final long failoverCount = retryInvocationHandler.getFailoverCount();
try {
  return invoke();
} catch (Exception e) {
  if (LOG.isTraceEnabled()) {
    LOG.trace(toString(), e);
  }
  if (Thread.currentThread().isInterrupted()) {
    // If interrupted, do not retry.
    throw e;
  }

  retryInfo = retryInvocationHandler.handleException(
      method, callId, retryPolicy, counters, failoverCount, e);
  return processWaitTimeAndRetryInfo();
}
{code}
Use InterruptedException to instead of them?

> [SBN read] ObserverReadProxyProvider should throw InterruptException
> --------------------------------------------------------------------
>
>                 Key: HDFS-14937
>                 URL: https://issues.apache.org/jira/browse/HDFS-14937
>             Project: Hadoop HDFS
>          Issue Type: Improvement
>            Reporter: xuzq
>            Assignee: xuzq
>            Priority: Major
>         Attachments: HDFS-14937-trunk-001.patch
>
>
> ObserverReadProxyProvider should throw InterruptException immediately if one 
> Observer catch InterruptException in invoking.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

---------------------------------------------------------------------
To unsubscribe, e-mail: hdfs-issues-unsubscr...@hadoop.apache.org
For additional commands, e-mail: hdfs-issues-h...@hadoop.apache.org

Reply via email to