You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ji...@apache.org on 2015/05/05 01:17:10 UTC
hadoop git commit: YARN-2725. Added test cases of retrying creating
znode in ZKRMStateStore. Contributed by Tsuyoshi Ozawa (cherry picked from
commit d701acc9c67adc578ba18035edde1166eedaae98)
Repository: hadoop
Updated Branches:
refs/heads/branch-2 4e77ee2f6 -> f71c49c5e
YARN-2725. Added test cases of retrying creating znode in ZKRMStateStore. Contributed by Tsuyoshi Ozawa
(cherry picked from commit d701acc9c67adc578ba18035edde1166eedaae98)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/f71c49c5
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f71c49c5
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f71c49c5
Branch: refs/heads/branch-2
Commit: f71c49c5e3e82f66127f73e0200b84418fdb6e44
Parents: 4e77ee2
Author: Jian He <ji...@apache.org>
Authored: Mon May 4 16:13:29 2015 -0700
Committer: Jian He <ji...@apache.org>
Committed: Mon May 4 16:17:01 2015 -0700
----------------------------------------------------------------------
hadoop-yarn-project/CHANGES.txt | 3 +++
.../server/resourcemanager/recovery/ZKRMStateStore.java | 2 +-
.../resourcemanager/recovery/TestZKRMStateStore.java | 11 +++++++++++
3 files changed, 15 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/f71c49c5/hadoop-yarn-project/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt
index 4bf3f51..f9eb34c 100644
--- a/hadoop-yarn-project/CHANGES.txt
+++ b/hadoop-yarn-project/CHANGES.txt
@@ -257,6 +257,9 @@ Release 2.8.0 - UNRELEASED
YARN-3375. NodeHealthScriptRunner.shouldRun() check is performing 3 times for
starting NodeHealthScriptRunner. (Devaraj K via wangda)
+ YARN-2725. Added test cases of retrying creating znode in ZKRMStateStore.
+ (Tsuyoshi Ozawa via jianhe)
+
Release 2.7.1 - UNRELEASED
INCOMPATIBLE CHANGES
http://git-wip-us.apache.org/repos/asf/hadoop/blob/f71c49c5/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java
index 9da6400..97dd029 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java
@@ -297,7 +297,7 @@ public class ZKRMStateStore extends RMStateStore {
createRootDir(amrmTokenSecretManagerRoot);
}
- private void createRootDir(final String rootPath) throws Exception {
+ protected void createRootDir(final String rootPath) throws Exception {
// For root dirs, we shouldn't use the doMulti helper methods
new ZKAction<String>() {
@Override
http://git-wip-us.apache.org/repos/asf/hadoop/blob/f71c49c5/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java
index 6b09d39..c632a06 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java
@@ -100,6 +100,15 @@ public class TestZKRMStateStore extends RMStateStoreTestBase {
return workingZnode + "/" + ROOT_ZNODE_NAME + "/" + RM_APP_ROOT + "/"
+ appId;
}
+
+ /**
+ * Emulating retrying createRootDir not to raise NodeExist exception
+ * @throws Exception
+ */
+ public void testRetryingCreateRootDir() throws Exception {
+ createRootDir(znodeWorkingPath);
+ }
+
}
public RMStateStore getRMStateStore() throws Exception {
@@ -148,6 +157,8 @@ public class TestZKRMStateStore extends RMStateStoreTestBase {
testDeleteStore(zkTester);
testRemoveApplication(zkTester);
testAMRMTokenSecretManagerStateStore(zkTester);
+ ((TestZKRMStateStoreTester.TestZKRMStateStoreInternal)
+ zkTester.getRMStateStore()).testRetryingCreateRootDir();
}
@Test (timeout = 60000)