The versions Ismaël linked are accurate for Java, but Python has lagged behind. I filed an issue for this recently, but haven't had time to fix it [1].
As a workaround, you can follow the instructions on the Flink runner page, selecting the tab "Adapt for: Portable (Java/Python/Go)" [2]. Since official Docker images for Flink 1.11 and 1.12 were not published, you will need to build them yourself from source. Check out the Beam release branch for the release you are using and run this command to build the job server: `./gradlew :runners:flink:1.12:job-server-container:docker`. Then you should be able to follow the rest of the instructions as they are. [1] https://issues.apache.org/jira/browse/BEAM-11475 [2] https://beam.apache.org/documentation/runners/flink/ On Mon, Dec 28, 2020 at 6:28 AM Ismaël Mejía <[email protected]> wrote: > It seems the website has not been updated with the latest changes. I > just opened https://github.com/apache/beam/pull/13620/files for this > > Just to clarify the newer versions of Flink are supported in these > versions: > > 2.21.0 - 2.24.0 Support for Flink 1.10.0 > 2.25.0 - 2.26.0 Support for Flink 1.11.0 > 2.27.0 Support for Flink 1.12.0 > > Ismaël > > On Sun, Dec 27, 2020 at 2:12 PM Günter Hipler <[email protected]> > wrote: > > > > 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 > > > > >
