Skip to content

Commit e5c7051

Browse files
Abacndurgaprasadml
andauthored
[#38708] Add Flink 2.0 to SDK pipeline options validation lists (#38726) (#38731)
Co-authored-by: Durgaprasad M L <durgaprasadmadikeri@gmail.com>
1 parent 865955a commit e5c7051

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

.github/actions/setup-default-test-properties/test-properties.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
},
1515
"JavaTestProperties": {
1616
"SUPPORTED_VERSIONS": ["8", "11", "17", "21", "25"],
17-
"FLINK_VERSIONS": ["1.17", "1.18", "1.19", "1.20"],
17+
"FLINK_VERSIONS": ["1.17", "1.18", "1.19", "1.20", "2.0"],
1818
"SPARK_VERSIONS": ["3"]
1919
},
2020
"GoTestProperties": {

sdks/python/apache_beam/options/pipeline_options.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2021,7 +2021,7 @@ def _add_argparse_args(cls, parser):
20212021
class FlinkRunnerOptions(PipelineOptions):
20222022

20232023
# These should stay in sync with gradle.properties.
2024-
PUBLISHED_FLINK_VERSIONS = ['1.17', '1.18', '1.19', '1.20']
2024+
PUBLISHED_FLINK_VERSIONS = ['1.17', '1.18', '1.19', '1.20', '2.0']
20252025

20262026
@classmethod
20272027
def _add_argparse_args(cls, parser):

sdks/typescript/src/apache_beam/runners/flink.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ import { JavaJarService } from "../utils/service";
2828
const MAGIC_HOST_NAMES = ["[local]", "[auto]"];
2929

3030
// These should stay in sync with gradle.properties.
31-
const PUBLISHED_FLINK_VERSIONS = ["1.17", "1.18", "1.19", "1.20"];
31+
const PUBLISHED_FLINK_VERSIONS = ["1.17", "1.18", "1.19", "1.20", "2.0"];
3232

3333
const defaultOptions = {
3434
flinkMaster: "[local]",

0 commit comments

Comments
 (0)