You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bigtop.apache.org by ev...@apache.org on 2017/07/01 13:37:11 UTC
[27/50] [abbrv] bigtop git commit: BIGTOP-2799. [Puppet] Flink
deployment failure on all supported OS
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 <ev...@apache.org>
Authored: Mon Jun 5 01:54:43 2017 +0000
Committer: Evans Ye <ev...@apache.org>
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,