durgaprasadml opened a new pull request, #38726:
URL: https://github.com/apache/beam/pull/38726
## What does this PR do?
This PR fixes the Flink 2.0 CLI validation mismatch reported in #38708.
Beam 2.72.0 already includes Flink 2.0 runner support and the documentation
reflects this, but the SDK option validation lists were not updated accordingly.
As a result, passing:
bash --flink_version 2.0
failed with:
text invalid choice: '2.0'
## Changes
- Added 2.0 to PUBLISHED_FLINK_VERSIONS in:
- sdks/python/apache_beam/options/pipeline_options.py
- sdks/typescript/src/apache_beam/runners/flink.ts
- Updated default CI Flink version metadata:
- .github/actions/setup-default-test-properties/test-properties.json
## Verification
Validated locally with:
bash python -c "from apache_beam.options.pipeline_options import
PipelineOptions, FlinkRunnerOptions; opts =
PipelineOptions(['--runner=FlinkRunner', '--flink_version=2.0']);
print(opts.view_as(FlinkRunnerOptions).flink_version)"
which now parses successfully and returns:
text 2.0
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
