You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@slider.apache.org by st...@apache.org on 2014/11/02 15:25:18 UTC
[06/50] git commit: SLIDER-583 Slider-HA:ClusterConnectivityIT failed
due to connection refused
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 <go...@apache.org>
Authored: Thu Oct 30 02:40:06 2014 -0700
Committer: Gour Saha <go...@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)