This is an automated email from the ASF dual-hosted git repository.
Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new cd8b009d9fc [#38708] Add Flink 2.0 to SDK pipeline options validation
lists (#38726)
cd8b009d9fc is described below
commit cd8b009d9fc37c19e6c1150616e6d70edb14e7e8
Author: Durgaprasad M L <[email protected]>
AuthorDate: Thu May 28 21:26:05 2026 +0530
[#38708] Add Flink 2.0 to SDK pipeline options validation lists (#38726)
---
.github/actions/setup-default-test-properties/test-properties.json | 2 +-
sdks/python/apache_beam/options/pipeline_options.py | 2 +-
sdks/typescript/src/apache_beam/runners/flink.ts | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/.github/actions/setup-default-test-properties/test-properties.json
b/.github/actions/setup-default-test-properties/test-properties.json
index e3f1d7a3abc..f06de5174e6 100644
--- a/.github/actions/setup-default-test-properties/test-properties.json
+++ b/.github/actions/setup-default-test-properties/test-properties.json
@@ -14,7 +14,7 @@
},
"JavaTestProperties": {
"SUPPORTED_VERSIONS": ["8", "11", "17", "21", "25"],
- "FLINK_VERSIONS": ["1.17", "1.18", "1.19", "1.20"],
+ "FLINK_VERSIONS": ["1.17", "1.18", "1.19", "1.20", "2.0"],
"SPARK_VERSIONS": ["3"]
},
"GoTestProperties": {
diff --git a/sdks/python/apache_beam/options/pipeline_options.py
b/sdks/python/apache_beam/options/pipeline_options.py
index 2533083f7e7..e3ab13e2512 100644
--- a/sdks/python/apache_beam/options/pipeline_options.py
+++ b/sdks/python/apache_beam/options/pipeline_options.py
@@ -2021,7 +2021,7 @@ class JobServerOptions(PipelineOptions):
class FlinkRunnerOptions(PipelineOptions):
# These should stay in sync with gradle.properties.
- PUBLISHED_FLINK_VERSIONS = ['1.17', '1.18', '1.19', '1.20']
+ PUBLISHED_FLINK_VERSIONS = ['1.17', '1.18', '1.19', '1.20', '2.0']
@classmethod
def _add_argparse_args(cls, parser):
diff --git a/sdks/typescript/src/apache_beam/runners/flink.ts
b/sdks/typescript/src/apache_beam/runners/flink.ts
index 5877d9186a4..8f80b971da2 100644
--- a/sdks/typescript/src/apache_beam/runners/flink.ts
+++ b/sdks/typescript/src/apache_beam/runners/flink.ts
@@ -28,7 +28,7 @@ import { JavaJarService } from "../utils/service";
const MAGIC_HOST_NAMES = ["[local]", "[auto]"];
// These should stay in sync with gradle.properties.
-const PUBLISHED_FLINK_VERSIONS = ["1.17", "1.18", "1.19", "1.20"];
+const PUBLISHED_FLINK_VERSIONS = ["1.17", "1.18", "1.19", "1.20", "2.0"];
const defaultOptions = {
flinkMaster: "[local]",
