有没有一个地方可以让我们快速参考和查看apachebeam和运行时环境（flink、spark等）之间的版本兼容性。我正在努力学习：（。不确定有多少问题是由版本不匹配造成的。
目前我使用的是beam 2.4.0和flink runner pom(https://search.maven.org/#artifactdetails%7corg.apache.beam%7cbeam-runners-flink\u 2.11%7c2.4.0%7cjar），它使用flink 1.4.0 jars。所以我假设ApacheBeam2.4.0与ApacheFlink1.4.0一起工作。这是正确的解释吗？
不幸的是，Flink1.4.0没有正式的docker映像(https://hub.docker.com/_/flink/)
1条答案
按热度按时间vvppvyoh1#
flink 1.4.0与beam 2.4.0兼容。找出兼容性的一个简单方法是检查beam发行版本的父pom.xml，并查看它是用哪个flink版本测试的。注意，这并不意味着它与其他flink版本不兼容。可能是，也可能不是，你需要找出或询问梁社区的人。