ci(helm): add helm chart

helm/templates/flink/deploy.yaml

@@ -0,0 +1,50 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: {{ .Release.Name }}-flink  # Adding the flink prefix to the name
+  labels:
+    app.kubernetes.io/name: {{ .Release.Name }}-flink  # Adding the flink prefix to the labels
+    app.kubernetes.io/instance: {{ .Release.Name }}  # Using the release name for instance
+    app.kubernetes.io/managed-by: Helm
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app.kubernetes.io/name: {{ .Release.Name }}-flink  # Adding the flink prefix to the selector
+      app.kubernetes.io/instance: {{ .Release.Name }}
+  template:
+    metadata:
+      labels:
+        app.kubernetes.io/name: {{ .Release.Name }}-flink  # Adding the flink prefix to the template labels
+        app.kubernetes.io/instance: {{ .Release.Name }}
+    spec:
+      containers:
+        - name: flink
+          image: {{ .Values.flink.image.repository }}:{{ .Values.flink.image.tag }}
+          imagePullPolicy: Always
+          ports:
+            - containerPort: 8081  # JobManager Web UI port
+            - containerPort: 6121  # TaskManager communication port
+            - containerPort: 6122  # TaskManager communication port
+          env:
+            - name: JOB_MANAGER_RPC_ADDRESS
+              value: "localhost"  # JobManager and TaskManager in the same container
+            - name: FLINK_PROPERTIES
+              value: |
+                jobmanager.rpc.address: localhost
+                taskmanager.numberOfTaskSlots: {{ .Values.flink.taskManager.numberOfTaskSlots }}
+                parallelism.default: {{ .Values.flink.parallelism.default }}
+                state.backend: {{ .Values.flink.state.backend }}
+                state.savepoints.dir: {{ .Values.flink.state.savepoints.dir }}  # Savepoints path
+          volumeMounts:
+            - name: flink-data
+              mountPath: /opt/flink/data
+            - name: flink-savepoints
+              mountPath: /opt/flink/savepoints
+
+      volumes:
+        - name: flink-data
+          emptyDir: {}  # Temporary storage for internal data
+        - name: flink-savepoints
+          persistentVolumeClaim:
+            claimName: {{ .Values.flink.state.savepoints.pvcName }}  # PVC for savepoints persistence

helm/templates/flink/pvc.yaml

@@ -0,0 +1,10 @@
+apiVersion: v1
+kind: PersistentVolumeClaim
+metadata:
+  name: {{ .Values.flink.state.savepoints.pvcName }}  # Adding the flink prefix to PVC name
+spec:
+  accessModes:
+    - ReadWriteOnce
+  resources:
+    requests:
+      storage: {{ .Values.flink.persistence.size }}  # Use size defined in values.yaml

helm/templates/flink/service.yaml

@@ -0,0 +1,15 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: {{ .Release.Name }}-flink-service  # Adding the flink prefix to the service name
+  labels:
+    app.kubernetes.io/name: {{ .Release.Name }}-flink  # Adding the flink prefix to labels
+    app.kubernetes.io/instance: {{ .Release.Name }}
+spec:
+  ports:
+    - port: 8081
+      targetPort: 8081
+  selector:
+    app.kubernetes.io/name: {{ .Release.Name }}-flink  # Adding the flink prefix to selector
+    app.kubernetes.io/instance: {{ .Release.Name }}
+  type: ClusterIP  # Change to LoadBalancer if you want external access