feat: update flink to 2.3

helm/chart/Chart.yaml

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

helm/chart/templates/flink/config.yaml

@@ -11,7 +11,11 @@
     taskmanager.data.port: 6125
     taskmanager.numberOfTaskSlots: {{ .Values.flink.taskManager.numberOfTaskSlots }}
     parallelism.default: {{ .Values.flink.parallelism.default }}
+    {{- if semverCompare ">=2.0.0" .Values.flink.version }}
+    state.backend.type: {{ .Values.flink.state.backend }}
+    {{- else }}
     state.backend: {{ .Values.flink.state.backend }}
+    {{- end }}
     rest.port: 8081
     rootLogger.level = DEBUG
     rootLogger.appenderRef.console.ref = ConsoleAppender
@@ -25,7 +29,11 @@
     {{- else if eq .Values.flink.state.checkpoint.storageType "s3" }}
     state.checkpoints.dir: s3://flink/checkpoints/
     {{- end }}
+    {{- if semverCompare ">=2.0.0" .Values.flink.version }}
+    state.backend.rocksdb.local-dir: /opt/flink/rocksdb
+    {{- else }}
     state.backend.rocksdb.localdir: /opt/flink/rocksdb
+    {{- end }}
     high-availability.storageDir: /opt/flink/ha
     {{- if eq .Values.flink.state.savepoint.storageType "filesystem" }}
     state.savepoints.dir: file:///opt/flink/savepoints/

helm/chart/values.yaml

@@ -113,9 +113,13 @@ affinity: {}
 
 # Global values for the Flink deployment
 flink:
+  # Flink major.minor version (semver string). Used by config template to emit
+  # the correct configuration key names for the target Flink version.
+  # Override to "1.20" for backward compatibility with Flink 1.20.x.
+  version: "2.3"
   image:
-    repository: lcr.logicamp.tech/library/flink
-    tag: 1.20.1-scala_2.12-java17-minicluster
+    repository: pcr.pishgaman.top/library/flink-kube-operator/flink
+    tag: 2.3.0-java21-v1.3.0
 
   parallelism:
     default: 1 # Default parallelism for Flink jobs