Потоковое объект не является членом пакета org.apache.flink.test - PullRequest
Новая
       11

Потоковое объект не является членом пакета org.apache.flink.test

0 голосов
/ 12 января 2019

Я получаю код clone flink из github и открываю его с помощью Intellij Idea, я не делал никаких настроек в IJ или в коде (я уже установил плагин IJ scala и установил scala sdk), я сразу иду, чтобы запустить следующие два примера в Intellij Idea

Я могу успешно запустить пример подсчета слов в пакетном режиме (код модуля org.apache.flink.examples.scala.wordcount.WordCount in flink-examples-batch_2.11).

Но когда я пытаюсь запустить пример подсчета потокового слова (код является модулем класса org.apache.flink.streaming.scala.examples.wordcount.WordCount in flink-examples-streaming_2.11), я получаю много ошибок компиляции: 

Error:(30, 30) object streaming is not a member of package org.apache.flink.test
import org.apache.flink.test.streaming.runtime.util.TestListResultSink
Error:(46, 36) not found: type TestListResultSink
    val sideOutputResultSink = new TestListResultSink[String]
Error:(47, 26) not found: type TestListResultSink
    val resultSink = new TestListResultSink[Int]
Error:(82, 36) not found: type TestListResultSink
    val sideOutputResultSink = new TestListResultSink[String]
Error:(83, 26) not found: type TestListResultSink
    val resultSink = new TestListResultSink[Int]
Error:(119, 36) not found: type TestListResultSink
    val sideOutputResultSink = new TestListResultSink[String]
Error:(120, 26) not found: type TestListResultSink
    val resultSink = new TestListResultSink[Int]
Error:(152, 26) not found: type TestListResultSink
    val resultSink = new TestListResultSink[String]
Error:(153, 30) not found: type TestListResultSink
    val lateResultSink = new TestListResultSink[(String, Int)]
Error:(196, 26) not found: type TestListResultSink
    val resultSink = new TestListResultSink[String]
Error:(197, 30) not found: type TestListResultSink
    val lateResultSink = new TestListResultSink[(String, Int)]
Error:(242, 26) not found: type TestListResultSink
    val resultSink = new TestListResultSink[String]
Error:(243, 36) not found: type TestListResultSink
    val sideOutputResultSink = new TestListResultSink[String]
Error:(289, 26) not found: type TestListResultSink
    val resultSink = new TestListResultSink[String]
Error:(290, 36) not found: type TestListResultSink
    val sideOutputResultSink = new TestListResultSink[String]

Ответы [ 3 ]

0 голосов
/ 13 января 2019

Я в итоге got org.apache.flink.examples.scala.wordcount.WordCount бегаю в IntelliJ, но это было нелегко. Я перепробовал множество вещей, но я думаю, что именно этот путь привел к успеху:

  1. проверил ветку release-1.7 (возможно, это не имеет значения, но я хотел убедиться, что у меня проверенный набор кода)
  2. построил весь проект из командной строки, через mvn clean package -DskipTests
  3. сделал Invalidate Caches / Restart в IntelliJ (я продолжал получать ошибки во время Build Project в IntelliJ, пока не сделал этого)
  4. Проект сборки (в IntelliJ)
  5. пробег org.apache.flink.examples.scala.wordcount.WordCount и org.apache.flink.streaming.scala.examples.wordcount.WordCount

FWIW, двоичные выпуски Flink поставляются с jar-файлами для некоторых примеров, которые можно запускать на кластере без необходимости что-либо компилировать. Это более простой способ запустить что-то. Подробности здесь .

0 голосов
/ 07 марта 2019

попробуйте собрать свой проект, затем запустите пример WordCount!

mvn clean package -DskipTests

0 голосов
/ 13 января 2019

Если я ищу TestListResultSink на GitHub.com, я нахожу его здесь . Это показывает, что это в модуле flink-tests. Вы включили это в настройку IntelliJ?

...