Repository: hadoop Updated Branches: refs/heads/branch-2 52f343598 -> fafcb4ac4
YARN-4113. RM should respect retry-interval when uses RetryPolicies.RETRY_FOREVER. (Sunil G via wangda) (cherry picked from commit b00392dd9cbb6778f2f3e669e96cf7133590dfe7) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/fafcb4ac Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/fafcb4ac Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/fafcb4ac Branch: refs/heads/branch-2 Commit: fafcb4ac4edec9881f8cc4ed4fd6c29b997481d3 Parents: 52f3435 Author: Wangda Tan <[email protected]> Authored: Mon Sep 21 11:04:03 2015 -0700 Committer: Wangda Tan <[email protected]> Committed: Mon Sep 21 11:15:02 2015 -0700 ---------------------------------------------------------------------- hadoop-yarn-project/CHANGES.txt | 3 +++ .../src/main/java/org/apache/hadoop/yarn/client/RMProxy.java | 3 ++- .../src/main/java/org/apache/hadoop/yarn/client/ServerProxy.java | 3 ++- 3 files changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/fafcb4ac/hadoop-yarn-project/CHANGES.txt ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt index 7ce6083..66aadcb 100644 --- a/hadoop-yarn-project/CHANGES.txt +++ b/hadoop-yarn-project/CHANGES.txt @@ -813,6 +813,9 @@ Release 2.8.0 - UNRELEASED YARN-4167. NPE on RMActiveServices#serviceStop when store is null. (Bibin A Chundatt via rohithsharmaks) + YARN-4113. RM should respect retry-interval when uses RetryPolicies.RETRY_FOREVER. + (Sunil G via wangda) + Release 2.7.2 - UNRELEASED INCOMPATIBLE CHANGES http://git-wip-us.apache.org/repos/asf/hadoop/blob/fafcb4ac/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java index 28628f3..be08f2f 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/RMProxy.java @@ -232,7 +232,8 @@ public class RMProxy<T> { RetryPolicy retryPolicy = null; if (waitForEver) { - retryPolicy = RetryPolicies.RETRY_FOREVER; + retryPolicy = RetryPolicies.retryForeverWithFixedSleep( + rmConnectionRetryIntervalMS, TimeUnit.MILLISECONDS); } else { retryPolicy = RetryPolicies.retryUpToMaximumTimeWithFixedSleep(rmConnectWaitMS, http://git-wip-us.apache.org/repos/asf/hadoop/blob/fafcb4ac/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/ServerProxy.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/ServerProxy.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/ServerProxy.java index de7fc7d..8c30fd7 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/ServerProxy.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/ServerProxy.java @@ -63,7 +63,8 @@ public class ServerProxy { RetryPolicy retryPolicy = null; if (maxWaitTime == -1) { // wait forever. - retryPolicy = RetryPolicies.RETRY_FOREVER; + retryPolicy = RetryPolicies.retryForeverWithFixedSleep(retryIntervalMS, + TimeUnit.MILLISECONDS); } else { retryPolicy = RetryPolicies.retryUpToMaximumTimeWithFixedSleep(maxWaitTime,
