Allow non-default config port for Storm.
diff --git a/app-packages/storm-v0_91/appConfig.json b/app-packages/storm-v0_91/appConfig.json
index e51c9b8..d6a6679 100644
--- a/app-packages/storm-v0_91/appConfig.json
+++ b/app-packages/storm-v0_91/appConfig.json
@@ -15,6 +15,7 @@
"site.global.ganglia_server_host": "${NN_HOST}",
"site.global.ganglia_server_id": "Application2",
"site.global.ganglia_enabled":"true",
+ "site.global.ganglia_server_port": "8668",
"site.global.rest_api_port": "${STORM_REST_API.ALLOCATED_PORT}",
"site.global.rest_api_admin_port": "${STORM_REST_API.ALLOCATED_PORT}",
"site.storm-site.topology.tuple.serializer": "backtype.storm.serialization.types.ListDelegateSerializer",
diff --git a/app-packages/storm-v0_91/package/scripts/params.py b/app-packages/storm-v0_91/package/scripts/params.py
index d459117..cf21b27 100644
--- a/app-packages/storm-v0_91/package/scripts/params.py
+++ b/app-packages/storm-v0_91/package/scripts/params.py
@@ -45,6 +45,7 @@
if ganglia_installed:
ganglia_report_interval = 60
ganglia_server = config['configurations']['global']['ganglia_server_host']
+ ganglia_port = config['configurations']['global']['ganglia_server_port']
_authentication = config['configurations']['core-site']['hadoop.security.authentication']
security_enabled = ( not is_empty(_authentication) and _authentication == 'kerberos')
diff --git a/app-packages/storm-v0_91/package/templates/config.yaml.j2 b/app-packages/storm-v0_91/package/templates/config.yaml.j2
index 89c8e67..32d2c99 100644
--- a/app-packages/storm-v0_91/package/templates/config.yaml.j2
+++ b/app-packages/storm-v0_91/package/templates/config.yaml.j2
@@ -35,7 +35,8 @@
reportInterval: {{ganglia_report_interval}}
# the hostname of the gmond server where storm cluster metrics will be sent
- host: "{{ganglia_server}}"
+ host: {{ganglia_server}}
+ port: {{ganglia_port}}
# address mode
# default is MULTICAST