.../java/org/apache/hadoop/yarn/webapp/JerseyTestBase.java | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/test/java/org/apache/hadoop/yarn/webapp/JerseyTestBase.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/test/java/org/apache/hadoop/yarn/webapp/JerseyTestBase.java index 0b177f9..7a225a3 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/test/java/org/apache/hadoop/yarn/webapp/JerseyTestBase.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/test/java/org/apache/hadoop/yarn/webapp/JerseyTestBase.java @@ -18,6 +18,9 @@ package org.apache.hadoop.yarn.webapp; +import java.io.IOException; + +import org.apache.hadoop.net.ServerSocketUtil; import org.junit.Before; import com.sun.jersey.test.framework.JerseyTest; import com.sun.jersey.test.framework.WebAppDescriptor; @@ -28,15 +31,8 @@ public JerseyTestBase(WebAppDescriptor appDescriptor) { } @Before - public void initializeJerseyPort() { - int jerseyPort = 9998; - String port = System.getProperty("jersey.test.port"); - if(null != port) { - jerseyPort = Integer.parseInt(port) + 10; - if(jerseyPort > 65535) { - jerseyPort = 9998; - } - } + public void initializeJerseyPort() throws IOException { + int jerseyPort = ServerSocketUtil.getPort(9998, 10); System.setProperty("jersey.test.port", Integer.toString(jerseyPort)); } }