SLIDER-583 Slider-HA:ClusterConnectivityIT failed due to connection refused
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/20b071e8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/20b071e8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/20b071e8 Branch: refs/heads/feature/SLIDER-531-registry-enhancements Commit: 20b071e87eda37625d17b53e7eafc40ef9c30363 Parents: 8c2e09f Author: Gour Saha <gourks...@apache.org> Authored: Thu Oct 30 02:40:06 2014 -0700 Committer: Gour Saha <gourks...@apache.org> Committed: Thu Oct 30 02:40:06 2014 -0700 ---------------------------------------------------------------------- .../slider/funtest/basic/ClusterConnectivityIT.groovy | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/20b071e8/slider-funtest/src/test/groovy/org/apache/slider/funtest/basic/ClusterConnectivityIT.groovy ---------------------------------------------------------------------- diff --git a/slider-funtest/src/test/groovy/org/apache/slider/funtest/basic/ClusterConnectivityIT.groovy b/slider-funtest/src/test/groovy/org/apache/slider/funtest/basic/ClusterConnectivityIT.groovy index b09e8b7..9826e97 100644 --- a/slider-funtest/src/test/groovy/org/apache/slider/funtest/basic/ClusterConnectivityIT.groovy +++ b/slider-funtest/src/test/groovy/org/apache/slider/funtest/basic/ClusterConnectivityIT.groovy @@ -65,13 +65,17 @@ class ClusterConnectivityIT extends CommandTestBase { @Test public void testRMTelnet() throws Throwable { - def rmAddr = SLIDER_CONFIG.getSocketAddr(YarnConfiguration.RM_ADDRESS, "", 0) - telnet(rmAddr.hostName, rmAddr.port) + def isHaEnabled = SLIDER_CONFIG.getTrimmed(YarnConfiguration.RM_HA_ENABLED) + // Telnet test is not straight forward for HA setup and is not required + // as long as RM binding is tested + if (!isHaEnabled) { + def rmAddr = SLIDER_CONFIG.getSocketAddr(YarnConfiguration.RM_ADDRESS, "", 0) + telnet(rmAddr.hostName, rmAddr.port) + } } @Test public void testRMBinding() throws Throwable { - testRMTelnet() SliderYarnClientImpl yarnClient = new SliderYarnClientImpl() try { SLIDER_CONFIG.setInt("ipc.client.connect.retry.interval",100)
