SLIDER-678: tests for liveness field in ClusterDescription: mock and minicluster
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/2dfdf334 Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/2dfdf334 Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/2dfdf334 Branch: refs/heads/develop Commit: 2dfdf3349092106241c2ec4357d3f83411d8b5f5 Parents: b75581b Author: Steve Loughran <[email protected]> Authored: Mon Feb 2 14:53:05 2015 +0000 Committer: Steve Loughran <[email protected]> Committed: Mon Feb 2 14:53:05 2015 +0000 ---------------------------------------------------------------------- .../apache/slider/agent/standalone/TestBuildStandaloneAM.groovy | 4 ++++ .../appmaster/model/appstate/TestMockAppStateFlexing.groovy | 5 +++++ 2 files changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/2dfdf334/slider-core/src/test/groovy/org/apache/slider/agent/standalone/TestBuildStandaloneAM.groovy ---------------------------------------------------------------------- diff --git a/slider-core/src/test/groovy/org/apache/slider/agent/standalone/TestBuildStandaloneAM.groovy b/slider-core/src/test/groovy/org/apache/slider/agent/standalone/TestBuildStandaloneAM.groovy index b6ac657..d72110e 100644 --- a/slider-core/src/test/groovy/org/apache/slider/agent/standalone/TestBuildStandaloneAM.groovy +++ b/slider-core/src/test/groovy/org/apache/slider/agent/standalone/TestBuildStandaloneAM.groovy @@ -168,5 +168,9 @@ class TestBuildStandaloneAM extends AgentMiniClusterTestBase { Map<String, String> masterRole = cd.getRole(master) assert masterRole != null, "Role hbase-master must exist" assert cd.roleNames.contains(master), "Role names must contain hbase-master" + + // and check liveness + assert cd.liveness.allRequestsSatisfied + assert 0 == cd.liveness.requestsOutstanding } } http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/2dfdf334/slider-core/src/test/groovy/org/apache/slider/server/appmaster/model/appstate/TestMockAppStateFlexing.groovy ---------------------------------------------------------------------- diff --git a/slider-core/src/test/groovy/org/apache/slider/server/appmaster/model/appstate/TestMockAppStateFlexing.groovy b/slider-core/src/test/groovy/org/apache/slider/server/appmaster/model/appstate/TestMockAppStateFlexing.groovy index dcb862d..d962438 100644 --- a/slider-core/src/test/groovy/org/apache/slider/server/appmaster/model/appstate/TestMockAppStateFlexing.groovy +++ b/slider-core/src/test/groovy/org/apache/slider/server/appmaster/model/appstate/TestMockAppStateFlexing.groovy @@ -20,6 +20,7 @@ package org.apache.slider.server.appmaster.model.appstate import groovy.util.logging.Slf4j import org.apache.hadoop.yarn.api.records.Container +import org.apache.slider.api.ClusterDescription import org.apache.slider.core.exceptions.TriggerClusterTeardownException import org.apache.slider.server.appmaster.model.mock.BaseMockAppStateTest import org.apache.slider.server.appmaster.model.mock.MockRoles @@ -94,6 +95,10 @@ class TestMockAppStateFlexing extends BaseMockAppStateTest implements MockRoles assert 1 == liveness.requestsOutstanding assert !liveness.allRequestsSatisfied + appState.refreshClusterStatus(null) + def cd = appState.clusterStatus + assert 1 == cd.liveness.requestsOutstanding + }
