Update validation workflows

Author: Manan Mangal

.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_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' ||

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>