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:
parent
86955c96ac
commit
eef07efe88
|
@ -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
|
||||
|
|
|
@ -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,
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue