diff options
| author | Evans Ye <evansye@apache.org> | 2017-06-05 01:54:43 +0000 |
|---|---|---|
| committer | Evans Ye <evansye@apache.org> | 2017-06-11 02:29:21 +0800 |
| commit | 062ae70500b73efd40a0d83cec035dbbb634bfc4 (patch) | |
| tree | ed0d78ef008b8db52c4b7ca806e56c505731a76d | |
| parent | 9b9a48f31f5a04da41e2e0d40b5ab2e557dd505a (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, |