This is an automated email from the ASF dual-hosted git repository.
tasanuma pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new b69ede7154d HADOOP-18191. Log retry count while handling exceptions in
RetryInvocationHandler (#4133)
b69ede7154d is described below
commit b69ede7154d44538a4a66824c34f7ba143deef25
Author: Viraj Jasani <[email protected]>
AuthorDate: Fri Apr 8 18:01:54 2022 +0530
HADOOP-18191. Log retry count while handling exceptions in
RetryInvocationHandler (#4133)
---
.../org/apache/hadoop/io/retry/RetryInvocationHandler.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/RetryInvocationHandler.java
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/RetryInvocationHandler.java
index fcc5975987e..3960b189665 100644
---
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/RetryInvocationHandler.java
+++
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/RetryInvocationHandler.java
@@ -387,12 +387,12 @@ public class RetryInvocationHandler<T> implements
RpcInvocationHandler {
throw retryInfo.getFailException();
}
- log(method, retryInfo.isFailover(), counters.failovers, retryInfo.delay,
e);
+ log(method, retryInfo.isFailover(), counters.failovers, counters.retries,
retryInfo.delay, e);
return retryInfo;
}
- private void log(final Method method, final boolean isFailover,
- final int failovers, final long delay, final Exception ex) {
+ private void log(final Method method, final boolean isFailover, final int
failovers,
+ final int retries, final long delay, final Exception ex) {
boolean info = true;
// If this is the first failover to this proxy, skip logging at INFO level
if (!failedAtLeastOnce.contains(proxyDescriptor.getProxyInfo().toString()))
@@ -408,13 +408,15 @@ public class RetryInvocationHandler<T> implements
RpcInvocationHandler {
}
final StringBuilder b = new StringBuilder()
- .append(ex + ", while invoking ")
+ .append(ex)
+ .append(", while invoking ")
.append(proxyDescriptor.getProxyInfo().getString(method.getName()));
if (failovers > 0) {
b.append(" after ").append(failovers).append(" failover attempts");
}
b.append(isFailover? ". Trying to failover ": ". Retrying ");
b.append(delay > 0? "after sleeping for " + delay + "ms.": "immediately.");
+ b.append(" Current retry count: ").append(retries).append(".");
if (info) {
LOG.info(b.toString());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
