From f0545c7fe483887420606ea61800970607f062f3 Mon Sep 17 00:00:00 2001
From: Joe Barefoot <joebarefoot@gmail.com>
Date: Thu, 4 Apr 2019 17:00:11 -0700
Subject: [PATCH] Fix so HA NN failover retry config is respected

---
 .../src/main/java/org/apache/hadoop/io/retry/RetryPolicies.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/RetryPolicies.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/RetryPolicies.java
index adf23c075f393..61ee695241dac 100644
--- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/RetryPolicies.java
+++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/RetryPolicies.java
@@ -656,7 +656,7 @@ private long getFailoverOrRetrySleepTime(int times) {
     @Override
     public RetryAction shouldRetry(Exception e, int retries,
         int failovers, boolean isIdempotentOrAtMostOnce) throws Exception {
-      if (failovers >= maxFailovers) {
+      if (failovers > maxFailovers) {
         return new RetryAction(RetryAction.RetryDecision.FAIL, 0,
             "failovers (" + failovers + ") exceeded maximum allowed ("
             + maxFailovers + ")");