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