flink版本:Apache Flink 1.7.2仅二进制。Scala:2.12
环境:
Scala version: 2.12.5
JDK: 1.8.0_171
我只是解开此存档并运行
bin/start-scala-shell.sh local
我有错误:
cannot find or load main class org.apache.flink.api.scala.FlinkShell.
错过了什么?
构建在Scala 2.12版本上的FLINK还不支持Flink Scala Shell。因此,如果要使用Flink Scala Shell,则应使用基于Scala 2.11构建的Flink二进制。来自 chesnay schepler 的消息,弗林克项目的参数:
这是意图的。增加Scala版本基本上打破了 Scala-shell,我们没有时间修复它。因此只是 可提供Scala 2.11。我同意错误消息可能是
更好。