feat(helm): add filesystem savepoint storage mode

helm/chart/Chart.yaml

@@ -2,9 +2,5 @@ apiVersion: v2
 name: flink-kube-operator
 description: Helm chart for flink kube operator
 type: application
-version: 1.1.1
+version: 1.2.0
 appVersion: "0.1.1"
-dependencies:
-  - name: minio
-    repository: https://charts.bitnami.com/bitnami
-    version: 16.0.2 

helm/chart/templates/flink/checkpoint-pvc.yaml

@@ -1,3 +1,4 @@
+{{- if eq .Values.flink.state.checkpoint.storageType "filesystem" }}
 apiVersion: v1
 kind: PersistentVolumeClaim
 metadata:
@@ -8,3 +9,4 @@ spec:
   resources:
     requests:
       storage: {{ .Values.flink.state.checkpoint.size }}
+{{- end }}

helm/chart/templates/flink/config.yaml

@@ -27,7 +27,11 @@
     {{- end }}
     state.backend.rocksdb.localdir: /opt/flink/rocksdb
     high-availability.storageDir: /opt/flink/ha
+    {{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
+    state.savepoints.dir: file:///opt/flink/checkpoints/
+    {{- else if eq .Values.flink.state.savepoint.storageType "s3" }}
     state.savepoints.dir: s3://flink/savepoints/
+    {{- end }}
     state.backend.incremental: {{ .Values.flink.state.incremental }}
     rest.profiling.enabled: true
     s3.endpoint: http://{{ .Release.Name }}-minio:9000

helm/chart/templates/flink/job-manager-deploy.yaml

@@ -68,6 +68,10 @@ spec:
             - name: flink-checkpoint
               mountPath: /opt/flink/checkpoints
             {{- end }}
+            {{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
+            - name: flink-savepoint
+              mountPath: /opt/flink/savepoint
+            {{- end }}
       volumes:
         - name: flink-ha
           persistentVolumeClaim:
@@ -77,6 +81,11 @@ spec:
           persistentVolumeClaim:
             claimName: {{ .Release.Name }}-flink-checkpoint-pvc
         {{- end }}
+        {{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
+        - name: flink-savepoint
+          persistentVolumeClaim:
+            claimName: {{ .Release.Name }}-flink-savepoint-pvc
+        {{- end }}
       {{- with .Values.nodeSelector }}
       nodeSelector:
         {{- toYaml . | nindent 8 }}

helm/chart/templates/flink/savepoint-pvc.yaml

@@ -0,0 +1,12 @@
+{{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
+apiVersion: v1
+kind: PersistentVolumeClaim
+metadata:
+  name: {{ .Release.Name }}-flink-savepoint-pvc
+spec:
+  accessModes:
+    - ReadWriteMany
+  resources:
+    requests:
+      storage: {{ .Values.flink.state.savepoint.size }}
+{{- end }}

helm/chart/templates/flink/task-manager-statefulset.yaml

@@ -43,6 +43,10 @@ spec:
             secretKeyRef:
               name: {{ .Release.Name }}-flink-secrets
               key: minio_secret_key
+        - name: FLINK_TASKMANAGER_HOST
+          valueFrom:
+            fieldRef:
+              fieldPath: spec.hostname
         volumeMounts:
         - name: rocksdb-storage
           mountPath: /opt/flink/rocksdb

helm/chart/values.yaml

@@ -38,8 +38,7 @@ podAnnotations: {}
 # For more information checkout: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/
 podLabels: {}
 
-podSecurityContext: {}
+podSecurityContext: {} # fsGroup: 2000
-  # fsGroup: 2000
 
 securityContext: {}
   # capabilities:
@@ -106,7 +105,6 @@ autoscaling:
 config:
   flinkApiUrl: flink:8081
 
-
 nodeSelector: {}
 
 tolerations: []
@@ -134,6 +132,9 @@ flink:
       interval: 5min
       mode: EXACTLY_ONCE
       size: 8Gi
+    savepoint:
+      storageType: s3
+      size: 8Gi
 
   jobManager:
     processMemory: 4096m # Size of job manager process memory
@@ -141,7 +142,6 @@ flink:
   properties:
     jobmanager.rpc.timeout: 300s
 
-
   taskManager:
     numberOfTaskSlots: 12 # Number of task slots for task manager
     processMemory: 4096m # Size of task manager process memory

helm/index.yaml

@@ -3,18 +3,32 @@ entries:
   flink-kube-operator:
   - apiVersion: v2
     appVersion: 0.1.1
-    created: "2025-04-13T10:37:39.948174933+03:30"
+    created: "2025-05-17T12:47:25.848097207+03:30"
     dependencies:
     - name: minio
       repository: https://charts.bitnami.com/bitnami
       version: 16.0.2
     description: Helm chart for flink kube operator
-    digest: 0b5f5e707279a564ad9e6c10fb3e565ff1af0ba2058b3f4bc04546dc8db8f68c
+    digest: 3458b9be97d2a4bcf8574706e44ea9f7fdeb11e83058a615566e6e094a51b920
     name: flink-kube-operator
     type: application
     urls:
-    - flink-kube-operator-1.1.1.tgz
+    - flink-kube-operator-1.2.0.tgz
-    version: 1.1.1
+    version: 1.2.0
+  - apiVersion: v2
+    appVersion: 0.1.1
+    created: "2025-04-15T12:06:59.425538953+03:30"
+    dependencies:
+    - name: minio
+      repository: https://charts.bitnami.com/bitnami
+      version: 16.0.2
+    description: Helm chart for flink kube operator
+    digest: 2b307a113476eebb34f58308bf1d4d0d36ca5e08fe6541f369a1c231ae0a71be
+    name: flink-kube-operator
+    type: application
+    urls:
+    - flink-kube-operator-1.1.2.tgz
+    version: 1.1.2
   - apiVersion: v2
     appVersion: 0.1.1
     created: "2025-04-12T23:13:39.394371646+03:30"
@@ -193,4 +207,4 @@ entries:
     urls:
     - flink-kube-operator-0.1.0.tgz
     version: 0.1.0
-generated: "2025-04-13T10:37:39.928098588+03:30"
+generated: "2025-04-15T12:06:59.397928815+03:30"