Невозможно запустить пример WordCount в Flink - PullRequest
Новая
       9

Невозможно запустить пример WordCount в Flink

0 голосов
/ 19 февраля 2019

После импорта pom из flink-release-1.4.2 я пытаюсь запустить пример wordcount. Но я не могу построить его из-за большого количества ошибок в 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)

Так что не так.И когда я импортирую только pom из flink-examples, программа wordcount могла работать нормально.Например:

run normally

Я попытался повторно импортировать Maven, сделать недействительными кэши и установить плагины Scala.

Ответы [ 2 ]

0 голосов
/ 21 февраля 2019

Проблема решена. Я запускаю mvn clean package -DskipTests и успешно перестраиваюсь.

0 голосов
/ 19 февраля 2019

С IntelliJ вам понадобится плагин JetBrains Scala, и вам нужно будет открыть диалоговое окно структуры проекта и добавить Scala SDK в раздел «Глобальные библиотеки».

...