Apache Flink 1.9.0 兼容 Apache Beam 版本

Question

Apache Flink 1.9.0 于 2019 年 8 月 22 日发布。我尝试了运行来自 Beam 2.15.0 和 Flink runner "beam-runners-flink-1.8" 的 Beam 字数统计示例，但它似乎没有工作。是否有 1.9.0 兼容的 flink runner 工件的 eta？

我在下面使用 Maven 依赖构建：

  <dependency>
      <groupId>org.apache.beam</groupId>
      <artifactId>beam-runners-flink-1.8</artifactId>
      <version>2.15.0</version>
      <scope>runtime</scope>
    </dependency>

错误提到作业图反序列化错误。

Answer 1

很抱歉回答我自己的问题，但看起来 Apache Beam JIRA 在这里：jira.apache.org/jira/browse/BEAM-7730 –

Apache Flink 1.9.0 兼容 Apache Beam 版本

Apache Flink 1.9.0 compatibility with Apache Beam version

apache-flink

apache-beam