[ 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