Skip to content

Commit 4c37742

Browse files
committed
2 parents 0d2e902 + 0eb7b71 commit 4c37742

19 files changed

Lines changed: 271 additions & 7 deletions

File tree

addons/airflow/2/chart/airflow/templates/worker/statefulset.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -274,7 +274,7 @@ spec:
274274
name: "data"
275275
{{- if or .Values.worker.persistence.annotations .Values.commonAnnotations }}
276276
{{- $claimAnnotations := include "common.tplvalues.merge" ( dict "values" ( list .Values.worker.persistence.annotations .Values.commonAnnotations ) "context" . ) }}
277-
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 4 }}
277+
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 10 }}
278278
{{- end }}
279279
{{- if .Values.commonLabels }}
280280
labels: {{- include "common.tplvalues.render" (dict "value" .Values.commonLabels "context" $) | nindent 10 }}

addons/airflow/3/chart/airflow-3/templates/worker/statefulset.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -335,7 +335,7 @@ spec:
335335
name: "data"
336336
{{- if or .Values.worker.persistence.annotations .Values.commonAnnotations }}
337337
{{- $claimAnnotations := include "common.tplvalues.merge" ( dict "values" ( list .Values.worker.persistence.annotations .Values.commonAnnotations ) "context" . ) }}
338-
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 4 }}
338+
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 10 }}
339339
{{- end }}
340340
{{- if .Values.commonLabels }}
341341
labels: {{- include "common.tplvalues.render" (dict "value" .Values.commonLabels "context" $) | nindent 10 }}

addons/flink/1.17/chart/flink/templates/taskmanager/statefulset.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ spec:
185185
name: "data"
186186
{{- if or .Values.taskmanager.persistence.annotations .Values.commonAnnotations }}
187187
{{- $claimAnnotations := include "common.tplvalues.merge" ( dict "values" ( list .Values.taskmanager.persistence.annotations .Values.commonAnnotations ) "context" . ) }}
188-
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 4 }}
188+
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 10 }}
189189
{{- end }}
190190
{{- if .Values.commonLabels }}
191191
labels: {{- include "common.tplvalues.render" (dict "value" .Values.commonLabels "context" $) | nindent 10 }}
Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
credential:
2+
{{- if (eq .Values.jobmanager.service.type "LoadBalancer") }}
3+
- name: JOBMANAGER_EXTERNAL_HOST
4+
valueFrom:
5+
serviceRef:
6+
name: {{ include "flink.jobmanager.fullname" . }}
7+
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
8+
{{- end }}
9+
10+
- name: JOBMANAGER_DOMAIN
11+
value: {{ include "flink.jobmanager.fullname" . }}.{{ .Release.Namespace }}.svc.{{ .Values.clusterDomain }}
12+
13+
- name: JOBMANAGER_HOST
14+
valueFrom:
15+
serviceRef:
16+
name: {{ include "flink.jobmanager.fullname" . }}
17+
jsonpath: '{ .spec.clusterIP }'
18+
19+
- name: JOBMANAGER_PORT_HTTP
20+
valueFrom:
21+
serviceRef:
22+
name: {{ include "flink.jobmanager.fullname" . }}
23+
jsonpath: '{ .spec.ports[?(@.name=="http")].port }'
24+
25+
- name: JOBMANAGER_PORT_RPC
26+
valueFrom:
27+
serviceRef:
28+
name: {{ include "flink.jobmanager.fullname" . }}
29+
jsonpath: '{ .spec.ports[?(@.name=="tcp-rpc")].port }'
30+
31+
- name: JOBMANAGER_PORT_BLOB
32+
valueFrom:
33+
serviceRef:
34+
name: {{ include "flink.jobmanager.fullname" . }}
35+
jsonpath: '{ .spec.ports[?(@.name=="tcp-blob")].port }'
Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
{
2+
"$schema": "http://json-schema.org/schema#",
3+
"type": "object",
4+
"properties": {
5+
"taskmanager": {
6+
"type": "object",
7+
"properties": {
8+
"persistence": {
9+
"type": "object",
10+
"properties": {
11+
"size": {
12+
"type": "string",
13+
"description": "persistence size",
14+
"pattern": "^(?:1Ti|(?:[1-9]\\d{0,2}|100[0-9]|101\\d|102[0-4])Gi)$"
15+
}
16+
}
17+
}
18+
}
19+
}
20+
}
21+
}
Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
name: "standard-4c10g5w"
2+
id: 1efdf417-6c42-46b4-9fba-6796419f9590
3+
description: "flink standard-4c10g5w plan which limit resources 4 cores 10G memory and 5 taskmanagers"
4+
displayName: "standard-4c10g5w"
5+
bindable: true
6+
maximum_polling_duration: 1800
Lines changed: 62 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,62 @@
1+
## @param fullnameOverride String to fully override common.names.fullname
2+
##
3+
fullnameOverride: hb-flink-standard-4c10g5w
4+
## @section Jobmanager deployment parameters
5+
##
6+
7+
jobmanager:
8+
## @param jobmanager.replicaCount Number of Apache Flink Jobmanager replicas
9+
##
10+
replicaCount: 1
11+
## Apache Flink pods' resource requests and limits
12+
## ref: https://kubernetes.io/docs/user-guide/compute-resources/
13+
## Minimum memory for development is 4GB and 2 CPU cores
14+
## Minimum memory for production is 8GB and 4 CPU cores
15+
## ref: http://docs.datastax.com/en/archived/flink/2.0/flink/architecture/architecturePlanningHardware_c.html
16+
resources:
17+
limits:
18+
cpu: 4
19+
memory: 10Gi
20+
requests:
21+
cpu: 500m
22+
memory: 1Gi
23+
## Apache Flink jobmanager.service parameters
24+
##
25+
service:
26+
## @param jobmanager.service.type Apache Flink service type
27+
##
28+
type: ClusterIP
29+
## @section TaskManager deployment parameters
30+
##
31+
32+
taskmanager:
33+
## @param taskmanager.replicaCount Number of Apache Flink replicas
34+
##
35+
replicaCount: 5
36+
## Apache Flink pods' resource requests and limits
37+
## ref: https://kubernetes.io/docs/user-guide/compute-resources/
38+
## Minimum memory for development is 4GB and 2 CPU cores
39+
## Minimum memory for production is 8GB and 4 CPU cores
40+
## ref: http://docs.datastax.com/en/archived/flink/2.0/flink/architecture/architecturePlanningHardware_c.html
41+
resources:
42+
limits:
43+
cpu: 4
44+
memory: 10Gi
45+
requests:
46+
cpu: 500m
47+
memory: 1Gi
48+
## @param taskmanager.extraEnvVars Extra environment variables to be set on flink container
49+
extraEnvVars:
50+
# taskmanager.numberOfTaskSlots
51+
- name: FLINK_TASK_MANAGER_NUMBER_OF_TASK_SLOTS
52+
value: "4"
53+
## Enable persistence using Persistent Volume Claims
54+
## ref: https://kubernetes.io/docs/user-guide/persistent-volumes/
55+
##
56+
persistence:
57+
## @param taskmanager.persistence.enabled Enable persistence using a `PersistentVolumeClaim`
58+
##
59+
enabled: true
60+
## @param taskmanager.persistence.size Persistent Volume Size
61+
##
62+
size: 8Gi

addons/opensearch/2.10/chart/opensearch/templates/data/statefulset.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -337,7 +337,7 @@ spec:
337337
name: "data"
338338
{{- if or .Values.data.persistence.annotations .Values.commonAnnotations }}
339339
{{- $claimAnnotations := include "common.tplvalues.merge" ( dict "values" ( list .Values.data.persistence.annotations .Values.commonAnnotations ) "context" . ) }}
340-
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 4 }}
340+
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 10 }}
341341
{{- end }}
342342
{{- if .Values.commonLabels }}
343343
labels: {{- include "common.tplvalues.render" (dict "value" .Values.commonLabels "context" $) | nindent 10 }}

addons/opensearch/2.10/chart/opensearch/templates/master/statefulset.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -349,7 +349,7 @@ spec:
349349
name: "data"
350350
{{- if or .Values.master.persistence.annotations .Values.commonAnnotations }}
351351
{{- $claimAnnotations := include "common.tplvalues.merge" ( dict "values" ( list .Values.master.persistence.annotations .Values.commonAnnotations ) "context" . ) }}
352-
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 4 }}
352+
annotations: {{- include "common.tplvalues.render" ( dict "value" $claimAnnotations "context" $) | nindent 10 }}
353353
{{- end }}
354354
{{- if .Values.commonLabels }}
355355
labels: {{- include "common.tplvalues.render" (dict "value" .Values.commonLabels "context" $) | nindent 10 }}
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
credential:
2+
{{- if (eq .Values.service.type "LoadBalancer") }}
3+
- name: EXTERNAL_HOST
4+
valueFrom:
5+
serviceRef:
6+
name: {{ template "common.names.fullname" . }}
7+
jsonpath: '{ .status.loadBalancer.ingress[*].ip }'
8+
{{- end }}
9+
10+
- name: DOMAIN
11+
value: {{ template "common.names.fullname" . }}.{{ .Release.Namespace }}.svc.{{ .Values.clusterDomain }}
12+
13+
- name: HOST
14+
valueFrom:
15+
serviceRef:
16+
name: {{ template "common.names.fullname" . }}
17+
jsonpath: '{ .spec.clusterIP }'
18+
19+
- name: PORT
20+
valueFrom:
21+
serviceRef:
22+
name: {{ template "common.names.fullname" . }}
23+
jsonpath: '{ .spec.ports[?(@.name=="tcp-redis")].port }'
24+
25+
- name: PROXY_PORT
26+
valueFrom:
27+
serviceRef:
28+
name: {{ template "common.names.fullname" . }}
29+
jsonpath: '{ .spec.ports[?(@.name=="tcp-proxy")].port }'
30+
31+
{{- if and .Values.usePassword (not .Values.existingSecret) }}
32+
- name: REDIS_PASSWORD
33+
valueFrom:
34+
secretKeyRef:
35+
name: {{ template "common.names.fullname" . }}
36+
jsonpath: '{ .data.redis-password }'
37+
{{- end }}

0 commit comments

Comments
 (0)