无法在flink中运行wordcount示例
无法在flink中运行wordcount示例
提问于 2019-02-20 02:33:01
在导入flink-release-1.4.2的pom后，我尝试运行wordcount Scala，但我无法构建它，因为关于example.But有很多错误。
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)那到底是怎么回事。当我只导入flink-examples的pom时，wordcount程序可以正常运行。例如：
我尝试过重新导入Maven、使缓存无效以及安装Scala插件。
回答 2
Stack Overflow用户
发布于 2019-02-20 04:16:44
对于IntelliJ，您将需要JetBrains Scala插件，并且您需要打开项目结构对话框，并在全局库部分添加Scala SDK。
Stack Overflow用户
发布于 2019-02-21 21:04:10
问题已解决。我运行mvn clean package -DskipTests并成功重建。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/54772827
复制相关文章
相似问题