Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-7357. Several methods in TestZKRMStateStore.TestZKRMStateStoreTester.TestZKRMStateStoreInternal should have @Override annotations 

(Contributed by Sen Zhao via Daniel Templeton)

(cherry picked from commit 0553f5a012e14c8ceb40a16161440384f9f3a9a8)
(cherry picked from commit 9da9023371)
This commit is contained in:
Daniel Templeton 2017-10-23 13:49:30 -07:00
parent 2b04ae918c
commit 08cfd010a3
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java
View File

@ -148,6 +148,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase {
return znodeWorkingPath + "/" + ROOT_ZNODE_NAME + "/" + VERSION_NODE; return znodeWorkingPath + "/" + ROOT_ZNODE_NAME + "/" + VERSION_NODE;
} }
@Override
public Version getCurrentVersion() { public Version getCurrentVersion() {
return CURRENT_VERSION_INFO; return CURRENT_VERSION_INFO;
} }
@ -197,6 +198,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase {
return createStore(conf); return createStore(conf);
} }
@Override
public RMStateStore getRMStateStore() throws Exception { public RMStateStore getRMStateStore() throws Exception {
YarnConfiguration conf = new YarnConfiguration(); YarnConfiguration conf = new YarnConfiguration();
return createStore(conf); return createStore(conf);
@ -220,6 +222,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase {
return store.getCurrentVersion(); return store.getCurrentVersion();
} }
@Override
public boolean appExists(RMApp app) throws Exception { public boolean appExists(RMApp app) throws Exception {
String appIdPath = app.getApplicationId().toString(); String appIdPath = app.getApplicationId().toString();
int split = int split =
@ -229,6 +232,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase {
.forPath(store.getAppNode(appIdPath, split)); .forPath(store.getAppNode(appIdPath, split));
} }
@Override
public boolean attemptExists(RMAppAttempt attempt) throws Exception { public boolean attemptExists(RMAppAttempt attempt) throws Exception {
ApplicationAttemptId attemptId = attempt.getAppAttemptId(); ApplicationAttemptId attemptId = attempt.getAppAttemptId();
return null != curatorFramework.checkExists() return null != curatorFramework.checkExists()
@ -278,6 +282,7 @@ public class TestZKRMStateStore extends RMStateStoreTestBase {
static class TestAppRejDispatcher extends TestDispatcher { static class TestAppRejDispatcher extends TestDispatcher {
private boolean appsavefailedEvnt; private boolean appsavefailedEvnt;
@Override
public void handle(Event event) { public void handle(Event event) {
if (event instanceof RMAppEvent && event.getType() if (event instanceof RMAppEvent && event.getType()
.equals(RMAppEventType.APP_SAVE_FAILED)) { .equals(RMAppEventType.APP_SAVE_FAILED)) {