This is an automated email from the ASF dual-hosted git repository.
ibzib 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 f2c9b6e [BEAM-9541] Update Python SDK's Flink version list.
new 7c4a21a8 Merge pull request #13810 from ibzib/flink-python-version
f2c9b6e is described below
commit f2c9b6e1aa5d38385f4c168107c85d4fe7f0f259
Author: Kyle Weaver <[email protected]>
AuthorDate: Tue Dec 29 14:24:13 2020 -0800
[BEAM-9541] Update Python SDK's Flink version list.
---
sdks/python/apache_beam/options/pipeline_options.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/options/pipeline_options.py
b/sdks/python/apache_beam/options/pipeline_options.py
index 96f445a..bda9df1 100644
--- a/sdks/python/apache_beam/options/pipeline_options.py
+++ b/sdks/python/apache_beam/options/pipeline_options.py
@@ -1214,7 +1214,8 @@ class JobServerOptions(PipelineOptions):
class FlinkRunnerOptions(PipelineOptions):
- PUBLISHED_FLINK_VERSIONS = ['1.7', '1.8', '1.9', '1.10']
+ # These should stay in sync with gradle.properties.
+ PUBLISHED_FLINK_VERSIONS = ['1.8', '1.9', '1.10', '1.11', '1.12']
@classmethod
def _add_argparse_args(cls, parser):
