Amazon EMR Flink上的Scala版本不匹配

Question

尝试在Amazon EMR Flink（5.21.0）上运行Flink（V 1.7.0）作业。我得到例外

java.lang.NoSuchMethodError: scala.Product.$init$(Lscala/Product;)V

异常看起来像Scala版本问题。我发现Flink库有Scala 2.11，并且使用2.12的工作构建。Flink 1.7.0支持Scala 2.12。

问题是，如何获得支持Scala 2.12而不是2.11的Amazon EMR？还是有更好的解决方案的其他我的代码回去2.11。

Answer 1

emr正在使用flink 1.6.1。这就是您要构建Flink Workflow的版本。

Answer 2

在文档中有一个描述，即如何手动安装要与EMR一起使用的任何版本的Flink。