Repository: bigtop Updated Branches: refs/heads/master 9b9a48f31 -> 062ae7050
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/062ae705 Tree: http://git-wip-us.apache.org/repos/asf/bigtop/tree/062ae705 Diff: http://git-wip-us.apache.org/repos/asf/bigtop/diff/062ae705 Branch: refs/heads/master Commit: 062ae70500b73efd40a0d83cec035dbbb634bfc4 Parents: 9b9a48f Author: Evans Ye <[email protected]> Authored: Mon Jun 5 01:54:43 2017 +0000 Committer: Evans Ye <[email protected]> Committed: Sun Jun 11 02:29:21 2017 +0800 ---------------------------------------------------------------------- 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/062ae705/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,
