github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-06 23:50:35 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-2369: Sqoop2: Use random port for AJP end point in TomcatSqoopMiniCluster

Browse Source 
(Guoquan Shen via Abraham Elmahrek)
This commit is contained in:
Abraham Elmahrek 2015-05-29 18:20:47 -07:00
parent 90d304bb0d
commit 06e9cdca47
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
test/src/main/java/org/apache/sqoop/test/minicluster/TomcatSqoopMiniCluster.java
View File

@ -34,6 +34,7 @@
import org.codehaus.cargo.container.installer.Installer; import org.codehaus.cargo.container.installer.Installer;
import org.codehaus.cargo.container.installer.ZipURLInstaller; import org.codehaus.cargo.container.installer.ZipURLInstaller;
import org.codehaus.cargo.container.property.ServletPropertySet; import org.codehaus.cargo.container.property.ServletPropertySet;
import org.codehaus.cargo.container.tomcat.TomcatPropertySet;
import org.codehaus.cargo.generic.DefaultContainerFactory; import org.codehaus.cargo.generic.DefaultContainerFactory;
import org.codehaus.cargo.generic.configuration.DefaultConfigurationFactory; import org.codehaus.cargo.generic.configuration.DefaultConfigurationFactory;
@ -46,6 +47,7 @@ public class TomcatSqoopMiniCluster extends SqoopMiniCluster {
private InstalledLocalContainer container = null; private InstalledLocalContainer container = null;
private Integer port; private Integer port;
private Integer ajpPort;
private static final Logger LOG = Logger.getLogger(TomcatSqoopMiniCluster.class); private static final Logger LOG = Logger.getLogger(TomcatSqoopMiniCluster.class);
@ -53,12 +55,14 @@ public class TomcatSqoopMiniCluster extends SqoopMiniCluster {
public TomcatSqoopMiniCluster(String temporaryPath) throws Exception { public TomcatSqoopMiniCluster(String temporaryPath) throws Exception {
super(temporaryPath); super(temporaryPath);
port = NetworkUtils.findAvailablePort(); port = NetworkUtils.findAvailablePort();
ajpPort = NetworkUtils.findAvailablePort();
} }
/** {@inheritDoc} */ /** {@inheritDoc} */
public TomcatSqoopMiniCluster(String temporaryPath, Configuration configuration) throws Exception { public TomcatSqoopMiniCluster(String temporaryPath, Configuration configuration) throws Exception {
super(temporaryPath, configuration); super(temporaryPath, configuration);
port = NetworkUtils.findAvailablePort(); port = NetworkUtils.findAvailablePort();
ajpPort = NetworkUtils.findAvailablePort();
} }
/** {@inheritDoc} */ /** {@inheritDoc} */
@ -136,6 +140,7 @@ public void start() throws Exception {
// Random port // Random port
configuration.setProperty(ServletPropertySet.PORT, port.toString()); configuration.setProperty(ServletPropertySet.PORT, port.toString());
configuration.setProperty(TomcatPropertySet.AJP_PORT, ajpPort.toString());
// Start Sqoop server // Start Sqoop server
LOG.info("Tomcat extract path: " + extractPath); LOG.info("Tomcat extract path: " + extractPath);