diff options
| -rw-r--r-- | bigtop-deploy/puppet/modules/flink/manifests/init.pp | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/bigtop-deploy/puppet/modules/flink/manifests/init.pp b/bigtop-deploy/puppet/modules/flink/manifests/init.pp index 221d62dd..e31d1828 100644 --- a/bigtop-deploy/puppet/modules/flink/manifests/init.pp +++ b/bigtop-deploy/puppet/modules/flink/manifests/init.pp @@ -37,23 +37,29 @@ class flink { class jobmanager { include flink::common + package { "flink-jobmanager": + ensure => latest, + } + service { "flink-jobmanager": ensure => running, - require => Package["flink"], + require => Package["flink-jobmanager"], subscribe => File["/etc/flink/conf/flink-conf.yaml"], hasrestart => true, hasstatus => true - } - } class taskmanager { include flink::common + package { "flink-taskmanager": + ensure => latest, + } + service { "flink-taskmanager": ensure => running, - require => Package["flink"], + require => Package["flink-taskmanager"], subscribe => File["/etc/flink/conf/flink-conf.yaml"], hasrestart => true, hasstatus => true, |