问带有Apache Flink 1.5的Apache Bean 2.4.0
EN

Stack Overflow用户

提问于 2018-06-14 05:39:57

回答 1查看 92关注 0票数 0

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

目前我使用的是光束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 (https://hub.docker.com/_/flink/)没有官方的docker镜像

发布于 2018-07-19 16:49:38

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

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/50846670

复制

相似问题

问带有Apache Flink 1.5的Apache Bean 2.4.0EN