Hi,

the compatibility matrix on
https://beam.apache.org/documentation/runners/flink/

says, beam versions >= 2.21.0 are only valid for Flink versions <= 1.10
and I get an error using a version higher than 1.10
mas_zb_demo_marc_author_count.py: error: argument --flink_version: invalid choice: '1.11' (choose from '1.7', '1.8', '1.9', '1.10')

On the other hand issues like this
https://issues.apache.org/jira/browse/BEAM-11191

are referencing Flink version 1.11 and the upcoming 2.27 release is referencing even Flink's version 1.12
https://issues.apache.org/jira/browse/BEAM-11419

Thanks for hints for some clarification

Günter


Reply via email to