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 e5cf95d07b1..f94bbd31b46 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 @@ -144,6 +144,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase { return znodeWorkingPath + "/" + ROOT_ZNODE_NAME + "/" + VERSION_NODE; } + @Override public Version getCurrentVersion() { return CURRENT_VERSION_INFO; } @@ -193,6 +194,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase { return createStore(conf); } + @Override public RMStateStore getRMStateStore() throws Exception { YarnConfiguration conf = new YarnConfiguration(); return createStore(conf); @@ -216,6 +218,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase { return store.getCurrentVersion(); } + @Override public boolean appExists(RMApp app) throws Exception { String appIdPath = app.getApplicationId().toString(); int split = @@ -225,6 +228,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase { .forPath(store.getAppNode(appIdPath, split)); } + @Override public boolean attemptExists(RMAppAttempt attempt) throws Exception { ApplicationAttemptId attemptId = attempt.getAppAttemptId(); return null != curatorFramework.checkExists() @@ -274,6 +278,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase { static class TestAppRejDispatcher extends TestDispatcher { private boolean appsavefailedEvnt; + @Override public void handle(Event event) { if (event instanceof RMAppEvent && event.getType() .equals(RMAppEventType.APP_SAVE_FAILED)) {