java - Cannot run wordcount example in flink
问题描述
After import pom of flink-release-1.4.2, I try to run wordcount example.But I cannot build it becauseof lots of errors about Scala.
Information:19-2-20 上午2:45 - Compilation completed with 53 errors and 0 warnings in 2s 439ms
/media/maple/新加卷/download/Notes/flink-release-1.4.2/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
Error:(81, 14) not found: type ExecutionEnvironment
val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment
Error:(81, 37) not found: value ExecutionEnvironment
val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment
Error:(85, 17) not found: type DataSet
val points: DataSet[Point] = getPointDataSet(params, env)
Error:(131, 74) not found: type DataSet
def getPointDataSet(params: ParameterTool, env: ExecutionEnvironment): DataSet[Point] = {
Error:(131, 51) not found: type ExecutionEnvironment
def getPointDataSet(params: ParameterTool, env: ExecutionEnvironment): DataSet[Point] = {
Error:(86, 20) not found: type DataSet
val centroids: DataSet[Centroid] = getCentroidDataSet(params, env)
So what's wrong. And when I only import pom of flink-examples, the wordcount program could run normally. For example:
I have tried reimport Maven, invalidate caches, and install Scala plugins.
解决方案
使用 IntelliJ,您需要 JetBrains Scala 插件,并且您需要打开项目结构对话框并在 Global Libraries 部分添加一个 Scala SDK。
推荐阅读
- vba - 如何从 ThisOutlookSession 运行 VBA?“宏”对话框打开
- terminal - 每次编译后如何清除 Angular CLI 命令行
- mysql - 使用数据透视表时如何选择?
- node.js - npm 安装的浏览器同步不起作用
- tensorflow - Tensorboard 中的 loss1 和 loss2 是什么?
- html - 如何放置 ampcssframework 的 css 成为有效的 AMP Page?
- python - 如何以字符串格式理解方括号内的大括号python代码以删除标点符号
- scalardb - 进行 Cassy 备份时显示警告消息
- python - 当我运行这样的脚本时,我需要在 babyname 之后添加数字(babyname1,babyname2,Infinite)
- c# - 如何等待不返回任何内容但操作需要使用的数据的任务?