HADOOP-12464. Interrupted client may try to fail-over and retry. Contributed by Kihwal Lee.
This commit is contained in:
parent
151eab2a12
commit
6144e0137b
|
@ -1365,6 +1365,8 @@ Release 2.7.2 - UNRELEASED
|
||||||
HADOOP-12465. Incorrect javadoc in WritableUtils.java.
|
HADOOP-12465. Incorrect javadoc in WritableUtils.java.
|
||||||
(Jagadesh Kiran N via aajisaka)
|
(Jagadesh Kiran N via aajisaka)
|
||||||
|
|
||||||
|
HADOOP-12464. Interrupted client may try to fail-over and retry (kihwal)
|
||||||
|
|
||||||
Release 2.7.1 - 2015-07-06
|
Release 2.7.1 - 2015-07-06
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -104,6 +104,10 @@ public class RetryInvocationHandler<T> implements RpcInvocationHandler {
|
||||||
hasMadeASuccessfulCall = true;
|
hasMadeASuccessfulCall = true;
|
||||||
return ret;
|
return ret;
|
||||||
} catch (Exception ex) {
|
} catch (Exception ex) {
|
||||||
|
if (Thread.currentThread().isInterrupted()) {
|
||||||
|
// If interrupted, do not retry.
|
||||||
|
throw ex;
|
||||||
|
}
|
||||||
boolean isIdempotentOrAtMostOnce = proxyProvider.getInterface()
|
boolean isIdempotentOrAtMostOnce = proxyProvider.getInterface()
|
||||||
.getMethod(method.getName(), method.getParameterTypes())
|
.getMethod(method.getName(), method.getParameterTypes())
|
||||||
.isAnnotationPresent(Idempotent.class);
|
.isAnnotationPresent(Idempotent.class);
|
||||||
|
|
|
@ -1428,20 +1428,14 @@ public class Client {
|
||||||
throw new IOException(e);
|
throw new IOException(e);
|
||||||
}
|
}
|
||||||
|
|
||||||
boolean interrupted = false;
|
|
||||||
synchronized (call) {
|
synchronized (call) {
|
||||||
while (!call.done) {
|
while (!call.done) {
|
||||||
try {
|
try {
|
||||||
call.wait(); // wait for the result
|
call.wait(); // wait for the result
|
||||||
} catch (InterruptedException ie) {
|
} catch (InterruptedException ie) {
|
||||||
// save the fact that we were interrupted
|
|
||||||
interrupted = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (interrupted) {
|
|
||||||
// set the interrupt flag now that we are done waiting
|
|
||||||
Thread.currentThread().interrupt();
|
Thread.currentThread().interrupt();
|
||||||
|
throw new InterruptedIOException("Call interrupted");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (call.error != null) {
|
if (call.error != null) {
|
||||||
|
|
Loading…
Reference in New Issue