|
@@ -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)) {
|