There has not been any decision to move to 1.6.x for the next release yet. There has been related general discussion about upgrading runners recently [1]
Overall we need to consider the support for newer Flink versions that users find (the Flink version in distributions and what users typically have in their deployment stacks). These upgrades are not automatic/cheap/fast, so there is a balance to strike. The good news is that with Beam 2.8.0 you should be able to make a build for 1.6.x with just a version number change [2] (Other compile differences have been cleaned up.) [1] https://lists.apache.org/thread.html/0588ed783767991aa36b00b8529bbd29b3a8958ee6e82fca83ac2938@%3Cdev.beam.apache.org%3E [2] https://github.com/apache/beam/blob/v2.8.0/runners/flink/build.gradle#L49 On Tue, Oct 30, 2018 at 10:50 AM Lukasz Cwik <lc...@google.com> wrote: > +dev <dev@beam.apache.org> > > On Tue, Oct 30, 2018 at 10:30 AM Jins George <jins.geo...@aeris.net> > wrote: > >> Hi Community, >> >> Noticed that the Beam 2.8 release comes with flink 1.5.x dependency. >> Are there any plans to upgrade flink to 1.6.x in next beam release. ( >> I am looking for the better k8s support in Flink 1.6) >> >> Thanks, >> >> Jins George >> >>
