Compare commits

..

2 Commits
v1.2.1 ... main

8 changed files with 49 additions and 9 deletions

View File

@ -2,5 +2,5 @@ apiVersion: v2
name: flink-kube-operator name: flink-kube-operator
description: Helm chart for flink kube operator description: Helm chart for flink kube operator
type: application type: application
version: 1.2.1 version: 1.2.3
appVersion: "0.1.1" appVersion: "0.1.1"

View File

@ -28,14 +28,16 @@
state.backend.rocksdb.localdir: /opt/flink/rocksdb state.backend.rocksdb.localdir: /opt/flink/rocksdb
high-availability.storageDir: /opt/flink/ha high-availability.storageDir: /opt/flink/ha
{{- if eq .Values.flink.state.savepoint.storageType "filesystem" }} {{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
state.savepoints.dir: file:///opt/flink/checkpoints/ state.savepoints.dir: file:///opt/flink/savepoints/
{{- else if eq .Values.flink.state.savepoint.storageType "s3" }} {{- else if eq .Values.flink.state.savepoint.storageType "s3" }}
state.savepoints.dir: s3://flink/savepoints/ state.savepoints.dir: s3://flink/savepoints/
{{- end }} {{- end }}
state.backend.incremental: {{ .Values.flink.state.incremental }} state.backend.incremental: {{ .Values.flink.state.incremental }}
rest.profiling.enabled: true rest.profiling.enabled: true
{{- if or (eq .Values.flink.state.checkpoint.storageType "s3") (eq .Values.flink.state.savepoint.storageType "s3") }}
s3.endpoint: http://{{ .Release.Name }}-minio:9000 s3.endpoint: http://{{ .Release.Name }}-minio:9000
s3.path.style.access: true s3.path.style.access: true
{{- end }}
{{- toYaml .Values.flink.properties | default "" | nindent 4 }} {{- toYaml .Values.flink.properties | default "" | nindent 4 }}
{{- end }} {{- end }}

View File

@ -49,6 +49,7 @@ spec:
valueFrom: valueFrom:
fieldRef: fieldRef:
fieldPath: status.podIP fieldPath: status.podIP
{{- if or (eq .Values.flink.state.checkpoint.storageType "s3") (eq .Values.flink.state.savepoint.storageType "s3") }}
- name: S3_ENDPOINT - name: S3_ENDPOINT
value: "http://minio-service:9000" value: "http://minio-service:9000"
- name: AWS_ACCESS_KEY_ID - name: AWS_ACCESS_KEY_ID
@ -61,6 +62,7 @@ spec:
secretKeyRef: secretKeyRef:
name: {{ .Release.Name }}-flink-secrets name: {{ .Release.Name }}-flink-secrets
key: minio_secret_key key: minio_secret_key
{{- end }}
volumeMounts: volumeMounts:
- name: flink-ha - name: flink-ha
mountPath: {{ .Values.flink.state.ha.dir }} mountPath: {{ .Values.flink.state.ha.dir }}
@ -70,7 +72,7 @@ spec:
{{- end }} {{- end }}
{{- if eq .Values.flink.state.savepoint.storageType "filesystem" }} {{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
- name: flink-savepoint - name: flink-savepoint
mountPath: /opt/flink/savepoint mountPath: /opt/flink/savepoints
{{- end }} {{- end }}
volumes: volumes:
- name: flink-ha - name: flink-ha

View File

@ -31,6 +31,7 @@ spec:
valueFrom: valueFrom:
fieldRef: fieldRef:
fieldPath: status.podIP fieldPath: status.podIP
{{- if or (eq .Values.flink.state.checkpoint.storageType "s3") (eq .Values.flink.state.savepoint.storageType "s3") }}
- name: S3_ENDPOINT - name: S3_ENDPOINT
value: "http://minio-service:9000" value: "http://minio-service:9000"
- name: AWS_ACCESS_KEY_ID - name: AWS_ACCESS_KEY_ID
@ -43,6 +44,7 @@ spec:
secretKeyRef: secretKeyRef:
name: {{ .Release.Name }}-flink-secrets name: {{ .Release.Name }}-flink-secrets
key: minio_secret_key key: minio_secret_key
{{- end }}
volumeMounts: volumeMounts:
- name: rocksdb-storage - name: rocksdb-storage
mountPath: /opt/flink/rocksdb mountPath: /opt/flink/rocksdb
@ -50,14 +52,24 @@ spec:
- name: flink-checkpoint - name: flink-checkpoint
mountPath: /opt/flink/checkpoints mountPath: /opt/flink/checkpoints
{{- end }} {{- end }}
{{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
- name: flink-savepoint
mountPath: /opt/flink/savepoints
{{- end }}
resources: resources:
{{- toYaml .Values.flink.taskManager.resources | nindent 10 }} {{- toYaml .Values.flink.taskManager.resources | nindent 10 }}
{{- if eq .Values.flink.state.checkpoint.storageType "filesystem" }}
volumes: volumes:
{{- if eq .Values.flink.state.checkpoint.storageType "filesystem" }}
- name: flink-checkpoint - name: flink-checkpoint
persistentVolumeClaim: persistentVolumeClaim:
claimName: {{ .Release.Name }}-flink-checkpoint-pvc claimName: {{ .Release.Name }}-flink-checkpoint-pvc
{{- end }} {{- end }}
{{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
- name: flink-savepoint
persistentVolumeClaim:
claimName: {{ .Release.Name }}-flink-savepoint-pvc
{{- end }}
volumeClaimTemplates: volumeClaimTemplates:
- metadata: - metadata:
name: rocksdb-storage name: rocksdb-storage

View File

@ -46,10 +46,11 @@ spec:
env: env:
- name: FLINK_API_URL - name: FLINK_API_URL
value: {{ .Release.Name }}-flink-job-manager:8081 value: {{ .Release.Name }}-flink-job-manager:8081
- name: SAVEPOINT_PATH
value: s3://flink/savepoints/
- name: NAMESPACE - name: NAMESPACE
value: "{{ .Release.Namespace }}" value: "{{ .Release.Namespace }}"
{{- if eq .Values.flink.state.savepoint.storageType "s3" }}
- name: SAVEPOINT_PATH
value: s3://flink/savepoints/
- name: S3_ENDPOINT - name: S3_ENDPOINT
value: "http://{{ .Release.Name }}-minio:9000" value: "http://{{ .Release.Name }}-minio:9000"
- name: AWS_ACCESS_KEY_ID - name: AWS_ACCESS_KEY_ID
@ -62,5 +63,8 @@ spec:
secretKeyRef: secretKeyRef:
name: {{ .Release.Name }}-minio name: {{ .Release.Name }}-minio
key: root-password key: root-password
{{- else }}
- name: SAVEPOINT_PATH
value: /opt/flink/savepoints/
{{- end }}

Binary file not shown.

Binary file not shown.

View File

@ -1,6 +1,26 @@
apiVersion: v1 apiVersion: v1
entries: entries:
flink-kube-operator: flink-kube-operator:
- apiVersion: v2
appVersion: 0.1.1
created: "2025-07-18T18:09:46.27166563+03:30"
description: Helm chart for flink kube operator
digest: 597f2c07884bb5411dcc6e1a9cdf7672977858efe30273a46fb6525eb6013091
name: flink-kube-operator
type: application
urls:
- flink-kube-operator-1.2.3.tgz
version: 1.2.3
- apiVersion: v2
appVersion: 0.1.1
created: "2025-05-17T14:34:55.317942453+03:30"
description: Helm chart for flink kube operator
digest: 422a34dc173ebe29adccd46d7ef94505cc022ff20ccbfb85ac3e6e201cba476c
name: flink-kube-operator
type: application
urls:
- flink-kube-operator-1.2.2.tgz
version: 1.2.2
- apiVersion: v2 - apiVersion: v2
appVersion: 0.1.1 appVersion: 0.1.1
created: "2025-05-17T14:01:29.891695937+03:30" created: "2025-05-17T14:01:29.891695937+03:30"
@ -217,4 +237,4 @@ entries:
urls: urls:
- flink-kube-operator-0.1.0.tgz - flink-kube-operator-0.1.0.tgz
version: 0.1.0 version: 0.1.0
generated: "2025-05-17T14:01:29.891695937+03:30" generated: "2025-07-18T18:09:46.244672127+03:30"