You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wayang.apache.org by rp...@apache.org on 2021/05/17 20:14:23 UTC
[incubator-wayang] 01/04: [WAYANG-30] Added the required yaml to
run Flink Cluster on Kubernetes
This is an automated email from the ASF dual-hosted git repository.
rpardomeza pushed a commit to branch debugger-sidecar
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 7a9a09c778e179163017f8d9b832964586580323
Author: rodrigopardomeza <ro...@gmail.com>
AuthorDate: Mon May 17 16:07:51 2021 -0400
[WAYANG-30] Added the required yaml to run Flink Cluster on Kubernetes
---
.../src/main/resources/jobmanager-service.yaml | 18 ++++++++++++
.../src/main/resources/jobmanager.yaml | 33 ++++++++++++++++++++++
.../src/main/resources/taskmanager.yaml | 31 ++++++++++++++++++++
3 files changed, 82 insertions(+)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager-service.yaml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager-service.yaml
new file mode 100644
index 0000000..a3c235a
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager-service.yaml
@@ -0,0 +1,18 @@
+apiVersion: v1
+kind: Service
+metadata:
+ name: jobmanager
+spec:
+ type: NodePort
+ ports:
+ - name: rpc
+ port: 6123
+ - name: blob
+ port: 6124
+ - name: query
+ port: 6125
+ - name: ui
+ port: 8081
+ selector:
+ app: flink
+ component: master
\ No newline at end of file
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager.yaml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager.yaml
new file mode 100644
index 0000000..6919861
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager.yaml
@@ -0,0 +1,33 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+ name: jobmanager
+spec:
+ selector:
+ matchLabels:
+ app: flink
+ replicas: 1
+ template:
+ metadata:
+ labels:
+ app: flink
+ component: master
+ spec:
+ containers:
+ - name: master
+ image: flink:1.13.0-scala_2.11-java8
+ workingDir: /opt/flink
+ args:
+ - jobmanager
+ ports:
+ - containerPort: 6123
+ name: rpc
+ - containerPort: 6124
+ name: blob
+ - containerPort: 6125
+ name: query
+ - containerPort: 6126
+ name: ui
+ env:
+ - name: JOB_MANAGER_RPC_ADDRESS
+ value: jobmanager
\ No newline at end of file
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/taskmanager.yaml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/taskmanager.yaml
new file mode 100644
index 0000000..03e1ae8
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/taskmanager.yaml
@@ -0,0 +1,31 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+ name: taskmanager
+spec:
+ selector:
+ matchLabels:
+ app: flink
+ replicas: 2
+ template:
+ metadata:
+ labels:
+ app: flink
+ component: task
+ spec:
+ containers:
+ - name: task
+ image: flink:1.13.0-scala_2.11-java8
+ workingDir: /opt/flink
+ args:
+ - taskmanager
+ ports:
+ - containerPort: 6121
+ name: data
+ - containerPort: 6122
+ name: rpc
+ - containerPort: 6125
+ name: query
+ env:
+ - name: JOB_MANAGER_RPC_ADDRESS
+ value: jobmanager
\ No newline at end of file