chore(addons): update flink meta updateable and kafka pvc RetentionPolicy

Author: jianxiaoguo

addons/flink/1/meta.yaml

@@ -13,7 +13,7 @@ tags: flink
 bindable: true
 instances_retrievable: true
 bindings_retrievable: true
-plan_updateable: false
+plan_updateable: true
 allow_parameters:
 - name: "jobmanager.service.type"
   required: false

addons/index.yaml

@@ -45,6 +45,9 @@ entries:
   fluentbit:
     - version: 2
       description: "High Performance Telemetry Agent for Logs, Metrics and Traces"
+  flink:
+    - version: 1
+      description: "Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams."
   kafka:
     - version: 3.6
       description: "Apache Kafka is an open-source distributed event streaming platform used by thousands of companies for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications."

addons/kafka/3.6/chart/kafka/templates/broker/statefulset.yaml

@@ -435,6 +435,11 @@ spec:
             claimName: {{ printf "%s" (tpl .Values.broker.logPersistence.existingClaim .) }}
         {{- end }}
   {{- if or (and .Values.broker.persistence.enabled (not .Values.broker.persistence.existingClaim)) (and .Values.broker.logPersistence.enabled (not .Values.broker.logPersistence.existingClaim)) }}
+  {{- if .Values.broker.persistentVolumeClaimRetentionPolicy.enabled }}
+  persistentVolumeClaimRetentionPolicy:
+    whenDeleted: {{ .Values.broker.persistentVolumeClaimRetentionPolicy.whenDeleted }}
+    whenScaled: {{ .Values.broker.persistentVolumeClaimRetentionPolicy.whenScaled }}
+  {{- end }}
   volumeClaimTemplates:
     {{- if and .Values.broker.persistence.enabled (not .Values.broker.persistence.existingClaim) }}
     - apiVersion: v1

addons/kafka/3.6/chart/kafka/templates/controller-eligible/statefulset.yaml

@@ -434,6 +434,11 @@ spec:
             claimName: {{ printf "%s" (tpl .Values.controller.logPersistence.existingClaim .) }}
         {{- end }}
   {{- if or (and .Values.controller.persistence.enabled (not .Values.controller.persistence.existingClaim)) (and .Values.controller.logPersistence.enabled (not .Values.controller.logPersistence.existingClaim)) }}
+  {{- if .Values.controller.persistentVolumeClaimRetentionPolicy.enabled }}
+  persistentVolumeClaimRetentionPolicy:
+    whenDeleted: {{ .Values.controller.persistentVolumeClaimRetentionPolicy.whenDeleted }}
+    whenScaled: {{ .Values.controller.persistentVolumeClaimRetentionPolicy.whenScaled }}
+  {{- end }}
   volumeClaimTemplates:
     {{- if and .Values.controller.persistence.enabled (not .Values.controller.persistence.existingClaim) }}
     - apiVersion: v1

addons/kafka/3.6/chart/kafka/values.yaml

@@ -828,6 +828,15 @@ controller:
     ## @param controller.persistence.mountPath Mount path of the Kafka data volume
     ##
     mountPath: /drycc/kafka
+  ## persistentVolumeClaimRetentionPolicy
+  ## ref: https://kubernetes.io/docs/concepts/workloads/controllers/statefulset/#persistentvolumeclaim-retention
+  ## @param persistentVolumeClaimRetentionPolicy.enabled Controls if and how PVCs are deleted during the lifecycle of a StatefulSet
+  ## @param persistentVolumeClaimRetentionPolicy.whenScaled Volume retention behavior when the replica count of the StatefulSet is reduced
+  ## @param persistentVolumeClaimRetentionPolicy.whenDeleted Volume retention behavior that applies when the StatefulSet is deleted
+  persistentVolumeClaimRetentionPolicy:
+    enabled: true
+    whenScaled: Delete
+    whenDeleted: Delete
   ## Log Persistence parameters
   ##
   logPersistence:
@@ -1228,6 +1237,15 @@ broker:
     ## @param broker.persistence.mountPath Mount path of the Kafka data volume
     ##
     mountPath: /drycc/kafka
+  ## persistentVolumeClaimRetentionPolicy
+  ## ref: https://kubernetes.io/docs/concepts/workloads/controllers/statefulset/#persistentvolumeclaim-retention
+  ## @param persistentVolumeClaimRetentionPolicy.enabled Controls if and how PVCs are deleted during the lifecycle of a StatefulSet
+  ## @param persistentVolumeClaimRetentionPolicy.whenScaled Volume retention behavior when the replica count of the StatefulSet is reduced
+  ## @param persistentVolumeClaimRetentionPolicy.whenDeleted Volume retention behavior that applies when the StatefulSet is deleted
+  persistentVolumeClaimRetentionPolicy:
+    enabled: true
+    whenScaled: Delete
+    whenDeleted: Delete
   ## Log Persistence parameters
   ##
   logPersistence: