Update for storm nimbus HA feature

Apache storm now supports nimbus.seeds option,
in which case the nimbus startup script should be
on all nodes, instead of only one in the cluster.

Change-Id: I660798e006605718035129758838e40ff1c972c3
This commit is contained in:
Brad Klein 2016-11-22 11:20:01 -07:00
parent 86955c96ac
commit eef07efe88
2 changed files with 7 additions and 13 deletions

View File

@ -19,7 +19,7 @@ get_up_list() {
echo "zookeeper kafka storm-supervisor"
if grep nimbus.host $STORM_FILE | grep -e $(hostname) -e localhost > /dev/null
if grep nimbus.seeds $STORM_FILE | grep -e $(hostname) -e localhost > /dev/null
then
echo "storm-nimbus storm-ui monasca-thresh"
fi

View File

@ -19,9 +19,6 @@
# [*log_dir*]
# directory for storm logs
#
# [*nimbus_server*]
# name of the nimbus server
#
class monasca::storm::config (
$storm_version = 'apache-storm-0.9.3',
$mirror = 'http://apache.arvixe.com/storm',
@ -29,7 +26,6 @@ class monasca::storm::config (
$storm_user = 'storm',
$storm_group = 'storm',
$log_dir = '/var/log/storm',
$nimbus_server = undef,
) {
$cache_dir = '/var/cache/storm'
$storm_local = '/storm-local'
@ -104,13 +100,11 @@ class monasca::storm::config (
storm_user => $storm_user,
}
if ($nimbus_server == 'localhost' or $nimbus_server == $::fqdn) {
File[$install_dir] -> File[$storm_local] ->
monasca::storm::startup_script {
'/etc/init.d/storm-nimbus':
storm_service => 'nimbus',
storm_install_dir => "${install_dir}/current",
storm_user => $storm_user,
}
File[$install_dir] -> File[$storm_local] ->
monasca::storm::startup_script {
'/etc/init.d/storm-nimbus':
storm_service => 'nimbus',
storm_install_dir => "${install_dir}/current",
storm_user => $storm_user,
}
}