Apache Bean 2.4.0 与 Apache Flink 1.5答案

【问题标题】：Apache Bean 2.4.0 with Apache Flink 1.5Apache Bean 2.4.0 与 Apache Flink 1.5
【发布时间】：2018-06-13 21:39:57
【问题描述】：

有没有一个地方可以让我们快速参考和查看 Apache Beam 和运行时环境（Flink、Spark 等）之间的版本兼容性。我正在艰难地学习它:(。不确定我的问题中有多少是由版本错误造成的。

目前我正在使用 Beam 2.4.0 并查看他的 flink runner pom (https://search.maven.org/#artifactdetails%7Corg.apache.beam%7Cbeam-runners-flink_2.11%7C2.4.0%7Cjar) ，它使用 flink 1.4.0 jars。所以我假设 Apache Beam 2.4.0 与 Apache Flink 1.4.0 一起工作。这是正确的解释吗？

很遗憾，Flink 1.4.0 没有官方的 docker 镜像 (https://hub.docker.com/_/flink/)

【问题讨论】：

【解决方案1】：

Flink 1.4.0 与 Beam 2.4.0 兼容。找出兼容性的一种简单方法是检查父 pom.xml 中的 Beam 发布版本，并查看它是使用哪个 Flink 版本进行测试的。请注意，这并不意味着它与其他 Flink 版本不兼容。可能是也可能不是，您需要在 Beam 社区中查找或询问某人。

【讨论】：