Flink疑难杂症【1】flink 如何运行scala程序?

flink 如何运行scala程序?

下载了github上的demo,链接如下:
Scala Examples for “Stream Processing with Apache Flink”

但是不知道怎么运行scala代码。

安排!

先参考了链接:
https://www.liujiajia.me/2019/9/10/package-flink-scala-project-with-intellij-idea

于是跟着操作,下载了sbt

下载了sbt和mvn,然后分别用这两种进行sbt clean package和mvn clean package,都报了错。

其中sbt报错如下:
在这里插入图片描述
mvn报错如下:
在这里插入图片描述

经过问题检索,发现可能是如下错误:
Scala: packages cannot be represented as URI
于是,我看了下我的电脑:

echo $JAVA_HOME

果然没有输出。

于是我照葫芦画瓢,先是查看了本机的java版本:

 java -version

结果如下:
java version “1.8.0_192”
Java™ SE Runtime Environment (build 1.8.0_192-b12)
Java HotSpot™ 64-Bit Server VM (build 25.192-b12, mixed mode)

于是,我改了改别人的命令:

export JAVA_HOME="/Library/Java/JavaVirtualMachines/jdk1.8.0_192.jdk/Contents/Home"

然后又一次的,我输入了:

mvn clean package

居然成功了!

在这里插入图片描述

于是,我在target目录中发现了生成的jar包。

生成jar包以后,我发现还是没办法运行某一个scala程序(包含main函数)。

点开一个程序后,发现idea自动提醒我是否setup scala SDK! 太可了!

于是,我轻松安装scala SDK:
在这里插入图片描述
之后就发现,在scala程序的object和main函数的左边有了绿色小三角,这说明点击就可以运行了!
在这里插入图片描述
这时候一定不可以得意忘配置,还是要编辑配置一下,下图中的对勾一定要选上。不然程序运行不起来。
在这里插入图片描述
呜呼~~~程序可以跑起来了!

猜你喜欢

转载自blog.csdn.net/FANFANHEBAOER/article/details/118225209