BIGTOP-2799. [Puppet] Flink deployment failure on all supported OS
Project: http://git-wip-us.apache.org/repos/asf/bigtop/repo Commit: http://git-wip-us.apache.org/repos/asf/bigtop/commit/80194e0c Tree: http://git-wip-us.apache.org/repos/asf/bigtop/tree/80194e0c Diff: http://git-wip-us.apache.org/repos/asf/bigtop/diff/80194e0c Branch: refs/heads/branch-1.2 Commit: 80194e0c0222323a42ea3053ee85d888563cb88e Parents: aac00e1 Author: Evans Ye <[email protected]> Authored: Mon Jun 5 01:54:43 2017 +0000 Committer: Evans Ye <[email protected]> Committed: Sat Jul 1 12:52:57 2017 +0000 ---------------------------------------------------------------------- bigtop-deploy/puppet/modules/flink/manifests/init.pp | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bigtop/blob/80194e0c/bigtop-deploy/puppet/modules/flink/manifests/init.pp ---------------------------------------------------------------------- diff --git a/bigtop-deploy/puppet/modules/flink/manifests/init.pp b/bigtop-deploy/puppet/modules/flink/manifests/init.pp index 221d62d..e31d182 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,
