Как запустить пример версии Java с подсчетом слов Flink в Zeppelin? - PullRequest
Новая
       8

Как запустить пример версии Java с подсчетом слов Flink в Zeppelin?

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

Нужно ли добавлять какие-либо зависимости в интерпретатор Flink?

Вот мой интерпретатор flink для интерпретатора flink на zeppelin:

enter image description here

А вот мой код в Zeppelin: пример примера java версии flink:

enter image description here

%flink

public class WordCountExample {
    public static void main(String[] args) throws Exception {
        final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        DataSet<String> text = env.fromElements(
            "Who's there?",
            "I think I hear them. Stand, ho! Who's there?");


        text.print();
    }
}

(для упрощения я просто получаю текст в наборе данныхи распечатывать его.)

Я получаю эту ошибку 

 ^

Понятия не имею, как запустить zeppelin.

...