时间戳

首页 > 解决方案 > Apache Flink 1.9.0 与 Apache Beam 版本的兼容性

apache-flink - Apache Flink 1.9.0 与 Apache Beam 版本的兼容性

问题描述

Apache Flink 1.9.0 于 2019 年 8 月 22 日发布。我尝试从 Beam 2.15.0 和 Flink 运行器“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>

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

标签： apache-flinkapache-beam

解决方案

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

推荐阅读