diff options
| author | Evans Ye <evansye@apache.org> | 2017-06-05 01:54:43 +0000 |
|---|---|---|
| committer | Evans Ye <evansye@apache.org> | 2017-07-01 12:52:57 +0000 |
| commit | 80194e0c0222323a42ea3053ee85d888563cb88e (patch) | |
| tree | c2a78f8f302ae51bd4c9d1bc9db3aea898aa1ea0 | |
| parent | aac00e1d937cac33cd534ded273ec803f1d289bc (diff) | |
BIGTOP-2799. [Puppet] Flink deployment failure on all supported OS
| -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, |