[ https://issues.apache.org/jira/browse/BEAM-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900109#comment-16900109 ]
David Moravek commented on BEAM-7730: ------------------------------------- I've managed to solve the serialization issues. Those were on the pipeline's side, where we were accessing OutputCollector from a different thread. Will send an initial PR once Flink 1.9-rc1 gets released. > 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: David Moravek > Priority: Major > Fix For: 2.16.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)