[
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: [email protected]
For additional commands, e-mail: [email protected]
