[
https://issues.apache.org/jira/browse/BEAM-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883736#comment-16883736
]
Maximilian Michels commented on BEAM-7730:
------------------------------------------
Hey [~sunjincheng121]! Adding a new Flink build target is quite easy if there
are no backwards-incompatible changes. You can see how it is done in the
{{runners/flink/1.x}} directories which all inherit from the
{{flink_runner.gradle}} base file with a few modifications to the source
directories which may be version-specific.
Once we add the 1.9 target, we may want to remove 1.5 because we already build
against four versions of Flink. There is some potential for simplification of
the code because of 1.5 specific workarounds in the code. For example, there is
the `preSnapshotBarrier` hook added in 1.6 that we had to workaround in 1.5 by
buffering elements in `snapshotState` instead. However, you do not have to
worry about this, we may do this separately.
> Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9
> -------------------------------------------------------------------------
>
> Key: BEAM-7730
> URL: https://issues.apache.org/jira/browse/BEAM-7730
> Project: Beam
> Issue Type: New Feature
> Components: runner-flink
> Reporter: sunjincheng
> Assignee: sunjincheng
> Priority: Major
> Fix For: 2.14.0
>
>
> Apache Flink 1.9 will coming and it's better to add Flink 1.9 build target
> and make Flink Runner compatible with Flink 1.9.
> I will add the brief changes after the Flink 1.9.0 released.
> And I appreciate it if you can leave your suggestions or comments!
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
