This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch release-2.0
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 15b71b3c473b1536f60f6b38c83d32eee0d81867
Author: Igal Shilman <igalshil...@gmail.com>
AuthorDate: Tue Mar 24 22:36:06 2020 +0100
[FLINK-16757] Reuse Helm charts in examples
This closes #72.
---
.../statefun-greeter-example/k8s/config-map.yaml | 45 ---------------
.../k8s/create-resources.sh} | 16 +++---
.../k8s/master-deployment.yaml | 65 ---------------------
.../k8s/master-rest-service.yaml | 28 ---------
.../k8s/master-service.yaml | 31 ----------
.../k8s/worker-deployment.yaml | 60 --------------------
statefun-examples/statefun-python-k8s/README.md | 4 +-
.../statefun-python-k8s/build-example.sh | 13 +++--
.../templates => }/python-worker-deployment.yaml | 10 ++--
.../templates => }/python-worker-service.yaml | 4 +-
.../resources/templates/config-map.yaml | 47 ---------------
.../resources/templates/master-deployment.yaml | 63 ---------------------
.../resources/templates/master-rest-service.yaml | 28 ---------
.../resources/templates/master-service.yaml | 31 ----------
.../resources/templates/worker-deployment.yaml | 66 ----------------------
.../statefun-python-k8s/resources/values.yaml | 35 ------------
16 files changed, 27 insertions(+), 519 deletions(-)
diff --git a/statefun-examples/statefun-greeter-example/k8s/config-map.yaml
b/statefun-examples/statefun-greeter-example/k8s/config-map.yaml
deleted file mode 100644
index e4372cf..0000000
--- a/statefun-examples/statefun-greeter-example/k8s/config-map.yaml
+++ /dev/null
@@ -1,45 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-apiVersion: v1
-kind: ConfigMap
-metadata:
- name: flink-config
- labels:
- app: statefun
-data:
- flink-conf.yaml: |+
- jobmanager.rpc.address: statefun-master
- taskmanager.numberOfTaskSlots: 1
- blob.server.port: 6124
- jobmanager.rpc.port: 6123
- taskmanager.rpc.port: 6122
- classloader.parent-first-patterns.additional:
org.apache.flink.statefun;org.apache.kafka;com.google.protobuf
- state.checkpoints.dir: file:///checkpoint-dir
- state.backend: rocksdb
- state.backend.rocksdb.timer-service.factory: ROCKSDB
- state.backend.incremental: true
- taskmanager.memory.total-process.size: 1g
-
- log4j-console.properties: |+
- log4j.rootLogger=INFO, console
- log4j.appender.console=org.apache.log4j.ConsoleAppender
- log4j.appender.console.layout=org.apache.log4j.PatternLayout
- log4j.appender.console.layout.ConversionPattern=%d{HH:mm:ss,SSS} %-5p
%-60c %x - %m%n
- log4j.logger.akka=INFO
- log4j.logger.org.apache.kafka=INFO
- log4j.logger.org.apache.hadoop=INFO
- log4j.logger.org.apache.zookeeper=INFO
-
log4j.logger.org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline=ERROR
diff --git a/statefun-examples/statefun-python-k8s/resources/Chart.yaml
b/statefun-examples/statefun-greeter-example/k8s/create-resources.sh
old mode 100644
new mode 100755
similarity index 81%
rename from statefun-examples/statefun-python-k8s/resources/Chart.yaml
rename to statefun-examples/statefun-greeter-example/k8s/create-resources.sh
index f9a582f..6fde8a3
--- a/statefun-examples/statefun-python-k8s/resources/Chart.yaml
+++ b/statefun-examples/statefun-greeter-example/k8s/create-resources.sh
@@ -1,3 +1,5 @@
+#!/bin/bash
+#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
@@ -12,10 +14,10 @@
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
-#
-apiVersion: v2
-name: statefun-demo
-description: A Helm chart for a multi-lang StateFun application deployed on
Kubernetes
-type: application
-version: 1.0.0
-appVersion: 1.16.0
\ No newline at end of file
+
+helm template ../../../tools/k8s \
+ --set worker.replicas=1 \
+ --set worker.image=greeter-example \
+ --set master.image=greeter-example
+
+
diff --git
a/statefun-examples/statefun-greeter-example/k8s/master-deployment.yaml
b/statefun-examples/statefun-greeter-example/k8s/master-deployment.yaml
deleted file mode 100644
index 073f684..0000000
--- a/statefun-examples/statefun-greeter-example/k8s/master-deployment.yaml
+++ /dev/null
@@ -1,65 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-apiVersion: apps/v1
-kind: Deployment
-metadata:
- name: statefun-master
-spec:
- replicas: 1
- selector:
- matchLabels:
- app: statefun
- component: master
- template:
- metadata:
- labels:
- app: statefun
- component: master
- spec:
- containers:
- - name: master
- image: greeter-example:latest
- imagePullPolicy: IfNotPresent
- args: ["--kafka-address=awsome-kafka-broker:9092"]
- env:
- - name: ROLE
- value: master
- - name: MASTER_HOST
- value: statefun-master
- ports:
- - containerPort: 6123
- name: rpc
- - containerPort: 6124
- name: blob
- - containerPort: 8081
- name: ui
- livenessProbe:
- tcpSocket:
- port: 6123
- initialDelaySeconds: 30
- periodSeconds: 60
- volumeMounts:
- - name: flink-config-volume
- mountPath: /opt/flink/conf
- volumes:
- - name: flink-config-volume
- configMap:
- name: flink-config
- items:
- - key: flink-conf.yaml
- path: flink-conf.yaml
- - key: log4j-console.properties
- path: log4j-console.properties
diff --git
a/statefun-examples/statefun-greeter-example/k8s/master-rest-service.yaml
b/statefun-examples/statefun-greeter-example/k8s/master-rest-service.yaml
deleted file mode 100644
index abef1e0..0000000
--- a/statefun-examples/statefun-greeter-example/k8s/master-rest-service.yaml
+++ /dev/null
@@ -1,28 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-apiVersion: v1
-kind: Service
-metadata:
- name: statefun-master-rest
-spec:
- type: NodePort
- ports:
- - name: rest
- port: 8081
- targetPort: 8081
- selector:
- app: statefun
- component: master
diff --git a/statefun-examples/statefun-greeter-example/k8s/master-service.yaml
b/statefun-examples/statefun-greeter-example/k8s/master-service.yaml
deleted file mode 100644
index a4e9d84..0000000
--- a/statefun-examples/statefun-greeter-example/k8s/master-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-apiVersion: v1
-kind: Service
-metadata:
- name: statefun-master
-spec:
- type: ClusterIP
- ports:
- - name: rpc
- port: 6123
- - name: blob
- port: 6124
- - name: ui
- port: 8081
- selector:
- app: statefun
- component: master
diff --git
a/statefun-examples/statefun-greeter-example/k8s/worker-deployment.yaml
b/statefun-examples/statefun-greeter-example/k8s/worker-deployment.yaml
deleted file mode 100644
index 8937e7c..0000000
--- a/statefun-examples/statefun-greeter-example/k8s/worker-deployment.yaml
+++ /dev/null
@@ -1,60 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-apiVersion: apps/v1
-kind: Deployment
-metadata:
- name: statefun-worker
-spec:
- replicas: 1
- selector:
- matchLabels:
- app: statefun
- component: worker
- template:
- metadata:
- labels:
- app: statefun
- component: worker
- spec:
- containers:
- - name: worker
- image: greeter-example:latest
- imagePullPolicy: IfNotPresent
- env:
- - name: ROLE
- value: worker
- - name: MASTER_HOST
- value: statefun-master
- ports:
- - containerPort: 6122
- name: rpc
- livenessProbe:
- tcpSocket:
- port: 6122
- initialDelaySeconds: 30
- periodSeconds: 60
- volumeMounts:
- - name: flink-config-volume
- mountPath: /opt/flink/conf
- volumes:
- - name: flink-config-volume
- configMap:
- name: flink-config
- items:
- - key: flink-conf.yaml
- path: flink-conf.yaml
- - key: log4j-console.properties
- path: log4j-console.properties
diff --git a/statefun-examples/statefun-python-k8s/README.md
b/statefun-examples/statefun-python-k8s/README.md
index bb78b7d..e0536a8 100644
--- a/statefun-examples/statefun-python-k8s/README.md
+++ b/statefun-examples/statefun-python-k8s/README.md
@@ -78,7 +78,9 @@ This should create the Docker images and generate a
`k8s-demo.yaml` file.
## Deploy
-`kubectl create -f k8s-demo.yaml`
+* `kubectl create -f k8s-demo.yaml`
+* `kubectl create -f python-worker-deployment.yaml`
+* `kubectl create -f python-worker-service.yaml`
## Generate events
diff --git a/statefun-examples/statefun-python-k8s/build-example.sh
b/statefun-examples/statefun-python-k8s/build-example.sh
index 0ba540d..399b0f2 100755
--- a/statefun-examples/statefun-python-k8s/build-example.sh
+++ b/statefun-examples/statefun-python-k8s/build-example.sh
@@ -41,14 +41,17 @@ rm -f apache_flink_statefun-*-py3-none-any.whl
# build the statefun Flink image
docker build -f Dockerfile.statefun . -t ${STATEFUN_IMAGE_NAME}
-helm template resources \
+helm template ../../tools/k8s \
--set worker.replicas=${PARALLELISM} \
--set worker.image=${STATEFUN_IMAGE_NAME} \
- --set python.image=${PYTHON_IMAGE_NAME} \
- --set python.name=${PYTHON_SERVICE_NAME} > ${K8S_RESOURCES_YAML}
+ --set master.image=${STATEFUN_IMAGE_NAME}
-echo "Successfully created ${STATEFUN_IMAGE_NAME}, ${PYTHON_IMAGE_NAME} Docker
images and ${K8S_RESOURCES_YAML}"
-echo "Upload these Docker images to your docker registry that is accssible
from K8S, and"
+echo "Successfully created ${STATEFUN_IMAGE_NAME}, ${PYTHON_IMAGE_NAME} Docker
images."
+echo "Upload these Docker images to your docker registry that is accessible
from K8S, and"
+echo ""
echo "Use: kubectl create -f ${K8S_RESOURCES_YAML}"
+echo "Use: kubectl create -f python-worker-deployment.yaml"
+echo "Use: kubectl create -f python-worker-service.yaml"
+
diff --git
a/statefun-examples/statefun-python-k8s/resources/templates/python-worker-deployment.yaml
b/statefun-examples/statefun-python-k8s/python-worker-deployment.yaml
similarity index 85%
rename from
statefun-examples/statefun-python-k8s/resources/templates/python-worker-deployment.yaml
rename to statefun-examples/statefun-python-k8s/python-worker-deployment.yaml
index 8ff3f49..05b9301 100644
---
a/statefun-examples/statefun-python-k8s/resources/templates/python-worker-deployment.yaml
+++ b/statefun-examples/statefun-python-k8s/python-worker-deployment.yaml
@@ -16,22 +16,22 @@
apiVersion: apps/v1
kind: Deployment
metadata:
- name: {{ .Values.python.name }}
+ name: statefun-python
spec:
- replicas: {{ .Values.python.replicas }}
+ replicas: 1
selector:
matchLabels:
app: statefun
- component: {{ .Values.python.name }}
+ component: statefun-python
template:
metadata:
labels:
app: statefun
- component: {{ .Values.python.name }}
+ component: statefun-python
spec:
containers:
- name: worker
- image: {{ .Values.python.image }}
+ image: k8s-demo-python-worker
ports:
- containerPort: 8000
name: endpoint
diff --git
a/statefun-examples/statefun-python-k8s/resources/templates/python-worker-service.yaml
b/statefun-examples/statefun-python-k8s/python-worker-service.yaml
similarity index 92%
rename from
statefun-examples/statefun-python-k8s/resources/templates/python-worker-service.yaml
rename to statefun-examples/statefun-python-k8s/python-worker-service.yaml
index bfa0fdc..534d70c 100644
---
a/statefun-examples/statefun-python-k8s/resources/templates/python-worker-service.yaml
+++ b/statefun-examples/statefun-python-k8s/python-worker-service.yaml
@@ -16,7 +16,7 @@
apiVersion: v1
kind: Service
metadata:
- name: {{ .Values.python.name }}
+ name: statefun-python
spec:
type: ClusterIP
ports:
@@ -24,4 +24,4 @@ spec:
port: 8000
selector:
app: statefun
- component: {{ .Values.python.name }}
+ component: statefun-python
diff --git
a/statefun-examples/statefun-python-k8s/resources/templates/config-map.yaml
b/statefun-examples/statefun-python-k8s/resources/templates/config-map.yaml
deleted file mode 100644
index a57e7ff..0000000
--- a/statefun-examples/statefun-python-k8s/resources/templates/config-map.yaml
+++ /dev/null
@@ -1,47 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-apiVersion: v1
-kind: ConfigMap
-metadata:
- name: flink-config
- labels:
- app: statefun
-data:
- flink-conf.yaml: |+
- jobmanager.rpc.address: {{ .Values.master.name }}
- taskmanager.numberOfTaskSlots: 1
- blob.server.port: 6124
- jobmanager.rpc.port: 6123
- taskmanager.rpc.port: 6122
- classloader.parent-first-patterns.additional:
org.apache.flink.statefun;org.apache.kafka;com.google.protobuf
- state.checkpoints.dir: {{ .Values.checkpoint.dir }}
- state.backend: rocksdb
- state.backend.rocksdb.timer-service.factory: ROCKSDB
- state.backend.incremental: true
- execution.checkpointing.interval: {{ .Values.checkpoint.interval }}
- taskmanager.memory.process.size: {{ .Values.worker.jvm_mem }}
- parallelism.default: {{ .Values.worker.replicas }}
-
- log4j-console.properties: |+
- log4j.rootLogger=INFO, console
- log4j.appender.console=org.apache.log4j.ConsoleAppender
- log4j.appender.console.layout=org.apache.log4j.PatternLayout
- log4j.appender.console.layout.ConversionPattern=%d{HH:mm:ss,SSS} %-5p
%-60c %x - %m%n
- log4j.logger.akka=INFO
- log4j.logger.org.apache.kafka=INFO
- log4j.logger.org.apache.hadoop=INFO
- log4j.logger.org.apache.zookeeper=INFO
-
log4j.logger.org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline=ERROR
diff --git
a/statefun-examples/statefun-python-k8s/resources/templates/master-deployment.yaml
b/statefun-examples/statefun-python-k8s/resources/templates/master-deployment.yaml
deleted file mode 100644
index e46e988..0000000
---
a/statefun-examples/statefun-python-k8s/resources/templates/master-deployment.yaml
+++ /dev/null
@@ -1,63 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-apiVersion: apps/v1
-kind: Deployment
-metadata:
- name: {{ .Values.master.name }}
-spec:
- replicas: 1
- selector:
- matchLabels:
- app: statefun
- component: master
- template:
- metadata:
- labels:
- app: statefun
- component: master
- spec:
- containers:
- - name: master
- image: {{ .Values.statefun_image }}
- env:
- - name: ROLE
- value: master
- - name: MASTER_HOST
- value: {{ .Values.master.name }}
- ports:
- - containerPort: 6123
- name: rpc
- - containerPort: 6124
- name: blob
- - containerPort: 8081
- name: ui
- livenessProbe:
- tcpSocket:
- port: 6123
- initialDelaySeconds: 30
- periodSeconds: 60
- volumeMounts:
- - name: flink-config-volume
- mountPath: /opt/flink/conf
- volumes:
- - name: flink-config-volume
- configMap:
- name: flink-config
- items:
- - key: flink-conf.yaml
- path: flink-conf.yaml
- - key: log4j-console.properties
- path: log4j-console.properties
diff --git
a/statefun-examples/statefun-python-k8s/resources/templates/master-rest-service.yaml
b/statefun-examples/statefun-python-k8s/resources/templates/master-rest-service.yaml
deleted file mode 100644
index d09861d..0000000
---
a/statefun-examples/statefun-python-k8s/resources/templates/master-rest-service.yaml
+++ /dev/null
@@ -1,28 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-apiVersion: v1
-kind: Service
-metadata:
- name: {{.Values.master.name}}-rest
-spec:
- type: NodePort
- ports:
- - name: rest
- port: 8081
- targetPort: 8081
- selector:
- app: statefun
- component: master
diff --git
a/statefun-examples/statefun-python-k8s/resources/templates/master-service.yaml
b/statefun-examples/statefun-python-k8s/resources/templates/master-service.yaml
deleted file mode 100644
index 116180a..0000000
---
a/statefun-examples/statefun-python-k8s/resources/templates/master-service.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-apiVersion: v1
-kind: Service
-metadata:
- name: {{ .Values.master.name }}
-spec:
- type: ClusterIP
- ports:
- - name: rpc
- port: 6123
- - name: blob
- port: 6124
- - name: ui
- port: 8081
- selector:
- app: statefun
- component: master
diff --git
a/statefun-examples/statefun-python-k8s/resources/templates/worker-deployment.yaml
b/statefun-examples/statefun-python-k8s/resources/templates/worker-deployment.yaml
deleted file mode 100644
index 2d1100a..0000000
---
a/statefun-examples/statefun-python-k8s/resources/templates/worker-deployment.yaml
+++ /dev/null
@@ -1,66 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-apiVersion: apps/v1
-kind: Deployment
-metadata:
- name: {{ .Values.worker.name }}
-spec:
- replicas: {{ .Values.worker.replicas }}
- selector:
- matchLabels:
- app: statefun
- component: worker
- template:
- metadata:
- labels:
- app: statefun
- component: worker
- spec:
- containers:
- - name: worker
- image: {{ .Values.statefun_image }}
- env:
- - name: ROLE
- value: worker
- - name: MASTER_HOST
- value: {{ .Values.master.name }}
- resources:
- requests:
- memory: "{{ .Values.worker.container_mem }}"
- ports:
- - containerPort: 6123
- name: rpc
- - containerPort: 6124
- name: blob
- - containerPort: 8081
- name: ui
- livenessProbe:
- tcpSocket:
- port: 6123
- initialDelaySeconds: 30
- periodSeconds: 60
- volumeMounts:
- - name: flink-config-volume
- mountPath: /opt/flink/conf
- volumes:
- - name: flink-config-volume
- configMap:
- name: flink-config
- items:
- - key: flink-conf.yaml
- path: flink-conf.yaml
- - key: log4j-console.properties
- path: log4j-console.properties
diff --git a/statefun-examples/statefun-python-k8s/resources/values.yaml
b/statefun-examples/statefun-python-k8s/resources/values.yaml
deleted file mode 100644
index cd07790..0000000
--- a/statefun-examples/statefun-python-k8s/resources/values.yaml
+++ /dev/null
@@ -1,35 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-checkpoint:
- dir: file:///checkpoint-dir
- interval: 10sec
-
-master:
- name: statefun-master
- image: statefun-demo
-
-worker:
- name: statefun-worker
- image: statefun-demo
- jvm_mem: 1g
- container_mem: 1.5Gi
- replicas: 3
-
-python:
- name: statefun-python
- image: k8s-demo-python-worker
- replicas: 1
-
