diff --git a/cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/services/AppFabricProcessorService.java b/cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/services/AppFabricProcessorService.java index f5f73dcebb8..97fafa95f81 100644 --- a/cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/services/AppFabricProcessorService.java +++ b/cdap-app-fabric/src/main/java/io/cdap/cdap/internal/app/services/AppFabricProcessorService.java @@ -26,6 +26,7 @@ import io.cdap.cdap.app.runtime.ProgramRuntimeService; import io.cdap.cdap.common.conf.CConfiguration; import io.cdap.cdap.common.conf.Constants; +import io.cdap.cdap.common.conf.Constants.AppFabric; import io.cdap.cdap.common.conf.Constants.Service; import io.cdap.cdap.common.conf.SConfiguration; import io.cdap.cdap.common.discovery.ResolvingDiscoverable; @@ -182,7 +183,7 @@ protected void startUp() throws Exception { Constants.AppFabric.DEFAULT_BOSS_THREADS)) .setWorkerThreadPoolSize(cConf.getInt(Constants.AppFabric.WORKER_THREADS, Constants.AppFabric.DEFAULT_WORKER_THREADS)) - .setPort(cConf.getInt(Constants.AppFabric.SERVER_PORT)); + .setPort(cConf.getInt(Constants.AppFabric.PROCESSOR_PORT)); if (sslEnabled) { new HttpsEnabler().configureKeyStore(cConf, sConf).enable(httpServiceBuilder); } @@ -217,7 +218,7 @@ private Cancellable startHttpService(NettyHttpService httpService) throws Except String announceAddress = cConf.get(Constants.Service.MASTER_SERVICES_ANNOUNCE_ADDRESS, httpService.getBindAddress().getHostName()); - int announcePort = cConf.getInt(Constants.AppFabric.SERVER_ANNOUNCE_PORT, + int announcePort = cConf.getInt(AppFabric.PROCESSOR_ANNOUNCE_PORT, httpService.getBindAddress().getPort()); final InetSocketAddress socketAddress = new InetSocketAddress(announceAddress, announcePort); diff --git a/cdap-common/src/main/java/io/cdap/cdap/common/conf/Constants.java b/cdap-common/src/main/java/io/cdap/cdap/common/conf/Constants.java index f231022e573..bf65338a1c3 100644 --- a/cdap-common/src/main/java/io/cdap/cdap/common/conf/Constants.java +++ b/cdap-common/src/main/java/io/cdap/cdap/common/conf/Constants.java @@ -229,11 +229,18 @@ public static final class Dangerous { */ public static final class AppFabric { + /** + * App Fabric Processor. + */ + + public static final String PROCESSOR_PORT = "appfabric.processor.bind.port"; + public static final String PROCESSOR_ANNOUNCE_PORT = "appfabric.processor.announce.port"; + /** * App Fabric Server. */ - public static final String SERVER_PORT = "app.bind.port"; - public static final String SERVER_ANNOUNCE_PORT = "app.announce.port"; + public static final String SERVER_PORT = "appfabric.bind.port"; + public static final String SERVER_ANNOUNCE_PORT = "appfabric.announce.port"; public static final String OUTPUT_DIR = "app.output.dir"; public static final String TEMP_DIR = "app.temp.dir"; public static final String REST_PORT = "app.rest.port"; diff --git a/cdap-common/src/main/resources/cdap-default.xml b/cdap-common/src/main/resources/cdap-default.xml index e1923f397ad..27ac6ce1ffa 100644 --- a/cdap-common/src/main/resources/cdap-default.xml +++ b/cdap-common/src/main/resources/cdap-default.xml @@ -514,10 +514,18 @@ - app.bind.port + appfabric.processor.bind.port 0 - App Fabric service bind port; if 0, binds to a random port + App Fabric processor bind port; if 0, binds to a random port + + + + + appfabric.bind.port + 0 + + App Fabric server bind port; if 0, binds to a random port