This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new 5d483357 [FLINK-39177] Enable Flink 2.2 tests and bump example flink
versions
5d483357 is described below
commit 5d4833574282b4bcf94c9c6e1af55f171e6edf97
Author: Gyula Fora <[email protected]>
AuthorDate: Fri Feb 27 12:16:12 2026 +0100
[FLINK-39177] Enable Flink 2.2 tests and bump example flink versions
---
.github/workflows/ci.yml | 16 ++++++++++------
docs/content/docs/custom-resource/reference.md | 2 ++
examples/advanced-ingress.yaml | 4 ++--
examples/basic-checkpoint-ha.yaml | 4 ++--
examples/basic-ingress.yaml | 4 ++--
examples/basic-reactive.yaml | 4 ++--
examples/basic-session-deployment-and-job.yaml | 4 ++--
examples/basic-session-deployment-only.yaml | 4 ++--
examples/basic.yaml | 4 ++--
examples/custom-logging.yaml | 4 ++--
examples/flink-beam-example/beam-example.yaml | 2 +-
.../flink-tls-example/basic-secure-deployment-only.yaml | 4 ++--
examples/flink-tls-example/basic-secure.yaml | 4 ++--
examples/pod-template.yaml | 4 ++--
examples/snapshot/job-from-savepoint.yaml | 4 ++--
.../flink/kubernetes/operator/api/spec/FlinkVersion.java | 4 +++-
16 files changed, 40 insertions(+), 32 deletions(-)
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index f0e04bc6..1f586365 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -71,7 +71,13 @@ jobs:
run: helm unittest ${{ env.HELM_CHART_DIR }}/${{
env.FLINK_OPERATOR_CHART }} --file "tests/**/*_test.yaml" --strict --debug
- name: Set up chart-testing
- uses:
helm/chart-testing-action@0d28d3144d3a25ea2cc349d6e59901c4ff469b3b
+ run: |
+ CT_VERSION=3.14.0
+ curl -sSLo /tmp/chart-testing.tar.gz
"https://github.com/helm/chart-testing/releases/download/v${CT_VERSION}/chart-testing_${CT_VERSION}_linux_amd64.tar.gz";
+ mkdir -p /tmp/ct
+ tar -xzf /tmp/chart-testing.tar.gz -C /tmp/ct
+ sudo mv /tmp/ct/ct /usr/local/bin/ct
+ sudo mv /tmp/ct/etc /etc/ct
- name: Run chart-testing (list-changed)
id: list-changed
@@ -150,10 +156,10 @@ jobs:
http-client: [ "okhttp" ]
java-version: [ "17"]
flink-version:
+ - "v2_2"
- "v2_1"
- "v2_0"
- "v1_20"
- - "v1_19"
uses: ./.github/workflows/e2e.yaml
with:
java-version: ${{ matrix.java-version }}
@@ -167,10 +173,10 @@ jobs:
strategy:
matrix:
flink-version:
+ - "v2_2"
- "v2_1"
- "v2_0"
- "v1_20"
- - "v1_19"
mode:
- "native"
- "standalone"
@@ -201,10 +207,10 @@ jobs:
strategy:
matrix:
flink-version:
+ - "v2_2"
- "v2_1"
- "v2_0"
- "v1_20"
- - "v1_19"
mode:
- "native"
- "standalone"
@@ -222,8 +228,6 @@ jobs:
exclude:
- mode: standalone
test: test_autoscaler.sh
- - flink-version: v1_19
- test: test_snapshot.sh
uses: ./.github/workflows/e2e.yaml
with:
java-version: 17
diff --git a/docs/content/docs/custom-resource/reference.md
b/docs/content/docs/custom-resource/reference.md
index 98d18e7d..35f6e9be 100644
--- a/docs/content/docs/custom-resource/reference.md
+++ b/docs/content/docs/custom-resource/reference.md
@@ -165,6 +165,8 @@ This serves as a full reference for FlinkDeployment and
FlinkSessionJob custom r
| v2_0 | |
| v2_1 | |
| v2_2 | |
+| v2_3 | |
+| v2_4 | |
| majorVersion | int | The major integer from the Flink semver. For example
for Flink 1.18.1 this would be 1. |
| minorVersion | int | The minor integer from the Flink semver. For example
for Flink 1.18.1 this would be 18. |
diff --git a/examples/advanced-ingress.yaml b/examples/advanced-ingress.yaml
index c83b923c..f1107c7d 100644
--- a/examples/advanced-ingress.yaml
+++ b/examples/advanced-ingress.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: advanced-ingress
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
ingress:
template: "/{{namespace}}/{{name}}(/|$)(.*)"
className: "nginx"
diff --git a/examples/basic-checkpoint-ha.yaml
b/examples/basic-checkpoint-ha.yaml
index 34d9dc1f..5d86ffd1 100644
--- a/examples/basic-checkpoint-ha.yaml
+++ b/examples/basic-checkpoint-ha.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-checkpoint-ha-example
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
taskmanager.numberOfTaskSlots: 2
state:
diff --git a/examples/basic-ingress.yaml b/examples/basic-ingress.yaml
index 42e5f778..6afb4cec 100644
--- a/examples/basic-ingress.yaml
+++ b/examples/basic-ingress.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-ingress
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
ingress:
template: "{{name}}.{{namespace}}.flink.k8s.io"
flinkConfiguration:
diff --git a/examples/basic-reactive.yaml b/examples/basic-reactive.yaml
index c51e584e..b77dad83 100644
--- a/examples/basic-reactive.yaml
+++ b/examples/basic-reactive.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-reactive-example
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
scheduler-mode: REACTIVE
taskmanager.numberOfTaskSlots: 2
diff --git a/examples/basic-session-deployment-and-job.yaml
b/examples/basic-session-deployment-and-job.yaml
index 5c7ff954..93657243 100644
--- a/examples/basic-session-deployment-and-job.yaml
+++ b/examples/basic-session-deployment-and-job.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-session-deployment-example
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
jobManager:
resource:
memory: "2048m"
diff --git a/examples/basic-session-deployment-only.yaml
b/examples/basic-session-deployment-only.yaml
index 26f06c03..6a1fb609 100644
--- a/examples/basic-session-deployment-only.yaml
+++ b/examples/basic-session-deployment-only.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-session-deployment-only-example
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
taskmanager.numberOfTaskSlots: 2
serviceAccount: flink
diff --git a/examples/basic.yaml b/examples/basic.yaml
index b4c94411..3eeb061c 100644
--- a/examples/basic.yaml
+++ b/examples/basic.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-example
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
taskmanager.numberOfTaskSlots: 2
serviceAccount: flink
diff --git a/examples/custom-logging.yaml b/examples/custom-logging.yaml
index 37821513..48044983 100644
--- a/examples/custom-logging.yaml
+++ b/examples/custom-logging.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: custom-logging-example
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
taskmanager.numberOfTaskSlots: 2
serviceAccount: flink
diff --git a/examples/flink-beam-example/beam-example.yaml
b/examples/flink-beam-example/beam-example.yaml
index 3bcab538..636a2789 100644
--- a/examples/flink-beam-example/beam-example.yaml
+++ b/examples/flink-beam-example/beam-example.yaml
@@ -22,7 +22,7 @@ metadata:
name: beam-example
spec:
image: flink-beam-example:latest
- flinkVersion: v1_19
+ flinkVersion: v2_2
flinkConfiguration:
taskmanager.numberOfTaskSlots: 1
serviceAccount: flink
diff --git a/examples/flink-tls-example/basic-secure-deployment-only.yaml
b/examples/flink-tls-example/basic-secure-deployment-only.yaml
index 91d8a458..63444371 100644
--- a/examples/flink-tls-example/basic-secure-deployment-only.yaml
+++ b/examples/flink-tls-example/basic-secure-deployment-only.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-secure-deployment-only
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
taskmanager.numberOfTaskSlots: "2"
security.ssl:
diff --git a/examples/flink-tls-example/basic-secure.yaml
b/examples/flink-tls-example/basic-secure.yaml
index 405eabac..163950f4 100644
--- a/examples/flink-tls-example/basic-secure.yaml
+++ b/examples/flink-tls-example/basic-secure.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: basic-secure
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
taskmanager.numberOfTaskSlots: 2
security.ssl:
diff --git a/examples/pod-template.yaml b/examples/pod-template.yaml
index 5c77f8c5..1f9e383b 100644
--- a/examples/pod-template.yaml
+++ b/examples/pod-template.yaml
@@ -21,8 +21,8 @@ kind: FlinkDeployment
metadata:
name: pod-template-example
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
taskmanager.numberOfTaskSlots: 2
serviceAccount: flink
diff --git a/examples/snapshot/job-from-savepoint.yaml
b/examples/snapshot/job-from-savepoint.yaml
index 4864578a..0dbba709 100644
--- a/examples/snapshot/job-from-savepoint.yaml
+++ b/examples/snapshot/job-from-savepoint.yaml
@@ -34,8 +34,8 @@ kind: FlinkDeployment
metadata:
name: example-deployment
spec:
- image: flink:1.20
- flinkVersion: v1_20
+ image: flink:2.2
+ flinkVersion: v2_2
flinkConfiguration:
state:
checkpoints.dir: file:///flink-data/checkpoints
diff --git
a/flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkVersion.java
b/flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkVersion.java
index 064bc213..8c1705fa 100644
---
a/flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkVersion.java
+++
b/flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkVersion.java
@@ -43,7 +43,9 @@ public enum FlinkVersion {
v1_20(1, 20),
v2_0(2, 0),
v2_1(2, 1),
- v2_2(2, 2);
+ v2_2(2, 2),
+ v2_3(2, 3),
+ v2_4(2, 4);
/** The major integer from the Flink semver. For example for Flink 1.18.1
this would be 1. */
private final int majorVersion;
