Update validation workflows

Author: Manan Mangal

.github/workflows/beam_PostCommit_Java_Examples_Flink.yml

@@ -80,7 +80,7 @@ jobs:
       - name: run examplesIntegrationTest script
         uses: ./.github/actions/gradle-command-self-hosted-action
         with:
-          gradle-command: :runners:flink:1.20:examplesIntegrationTest
+          gradle-command: :runners:flink:2.2:examplesIntegrationTest
       - name: Archive JUnit Test Results
         uses: actions/upload-artifact@v7
         if: ${{ !success() }}

.github/workflows/beam_PostCommit_Java_Nexmark_Flink.yml

@@ -102,7 +102,7 @@ jobs:
         with:
           gradle-command: :sdks:java:testing:nexmark:run
           arguments: |
-            -Pnexmark.runner=:runners:flink:1.20 \
+            -Pnexmark.runner=:runners:flink:2.2 \
              "${{ env.GRADLE_COMMAND_ARGUMENTS }} --streaming=${{ matrix.streaming }} --queryLanguage=${{ matrix.queryLanguage }}" \
       - name: run PostCommit Java Nexmark Flink (${{ matrix.streaming }}) script
         if: matrix.queryLanguage == 'none'

.github/workflows/beam_PostCommit_Java_PVR_Flink_Batch.yml

@@ -69,7 +69,7 @@ jobs:
         job_name: ["beam_PostCommit_Java_PVR_Flink_Batch"]
         job_phrase: ["Run Java_PVR_Flink_Batch PostCommit"]
         # every major version
-        flink_version: ['1.20', '2.0']
+        flink_version: ['1.20', '2.0', '2.1', '2.2']
     timeout-minutes: 240
     runs-on: [self-hosted, ubuntu-24.04, highmem]
     if: |

.github/workflows/beam_PostCommit_Java_PVR_Flink_Streaming.yml

@@ -60,7 +60,7 @@ jobs:
         job_name: [beam_PostCommit_Java_PVR_Flink_Streaming]
         job_phrase: [Run Java Flink PortableValidatesRunner Streaming]
         # every major version
-        flink_version: [ '1.20', '2.0', '2.2']
+        flink_version: [ '1.20', '2.0', '2.1', '2.2']
     if: |
       github.event_name == 'workflow_dispatch' ||
       github.event_name == 'pull_request_target' ||

.github/workflows/beam_PostCommit_Java_Tpcds_Flink.yml

@@ -101,5 +101,5 @@ jobs:
         with:
           gradle-command: :sdks:java:testing:tpcds:run
           arguments: |
-            -Ptpcds.runner=:runners:flink:1.20 \
+            -Ptpcds.runner=:runners:flink:2.2 \
             "-Ptpcds.args=${{env.tpcdsBigQueryArgs}} ${{env.tpcdsInfluxDBArgs}} ${{ env.GRADLE_COMMAND_ARGUMENTS }} --queries=${{env.tpcdsQueriesArg}}" \

.github/workflows/beam_PostCommit_Java_ValidatesRunner_Flink.yml

@@ -58,7 +58,7 @@ jobs:
         job_name: [beam_PostCommit_Java_ValidatesRunner_Flink]
         job_phrase: [Run Flink ValidatesRunner]
         # every major version
-        flink_version: ['1.20', '2.0', '2.2']
+        flink_version: ['1.20', '2.0', '2.1', '2.2']
     if: |
       github.event_name == 'workflow_dispatch' ||
       github.event_name == 'pull_request_target' ||

.github/workflows/beam_PostCommit_XVR_Flink.yml

@@ -47,7 +47,7 @@ env:
   DEVELOCITY_ACCESS_KEY: ${{ secrets.DEVELOCITY_ACCESS_KEY }}
   GRADLE_ENTERPRISE_CACHE_USERNAME: ${{ secrets.GE_CACHE_USERNAME }}
   GRADLE_ENTERPRISE_CACHE_PASSWORD: ${{ secrets.GE_CACHE_PASSWORD }}
-  FlinkVersion: 1.20
+  FlinkVersion: 2.2
 
 jobs:
   beam_PostCommit_XVR_Flink:

CHANGES.md

@@ -62,6 +62,7 @@
 * Python SDK now supports memory profiling with Memray ([#38853](https://github.com/apache/beam/issues/38853)).
 * (Python) Added [Qdrant](https://qdrant.tech/) VectorDatabaseWriteConfig implementation ([#38141](https://github.com/apache/beam/issues/38141)).
 
+
 ## I/Os
 
 * Support for reading from Delta Lake added (Java) ([#38551](https://github.com/apache/beam/issues/38551)).

runners/flink/2.2/build.gradle

@@ -19,8 +19,8 @@
 // Flink 2.2 API changes addressed in this module's source overrides:
 // - CheckpointingMode moved (Flink 2.2): org.apache.flink.streaming.api.CheckpointingMode
 //   is now @Deprecated; canonical path is org.apache.flink.core.execution.CheckpointingMode.
-//   FlinkExecutionEnvironments.java and FlinkPipelineOptionsTest.java are overridden here
-//   to use the non-deprecated import.
+//   FlinkExecutionEnvironments.java, DoFnOperator.java, and FlinkPipelineOptionsTest.java
+//   are overridden here to use the non-deprecated import.
 //
 // Flink 2.2 breaking changes that are SQL/cluster-layer only (no runner code change needed):
 // - TLS cipher suite default changed (FLINK-39022): JDK 11.0.30+/17.0.18+/21.0.10+/24+

website/www/site/content/en/documentation/runners/flink.md

@@ -335,6 +335,11 @@ To find out which version of Flink is compatible with Beam please see the table
   <td>beam-runners-flink-2.2</td>
   <td>&ge; 2.75.0</td>
 </tr>
+<tr>
+  <td>2.1.x</td>
+  <td>beam-runners-flink-2.1</td>
+  <td>&ge; 2.75.0</td>
+</tr>
 <tr>
   <td>2.0.x</td>
   <td>beam-runners-flink-2.0</td>