apache-flink

0зной

1ответ

Flink java.lang.ClassNotFoundException: play.api.libs.json.Reads

Я пишу код, который читает из текстового файла и анализирует каждую строку как Json, но задание в Flink (1.0.3 - Cluster 2 Taskmanagers) терпит неудачу с го excetion: java.lang.ClassNotFoundException:

0зной

1ответ

Почему flink останавливает приложение моего потока?

В моем коде используется readTextFile для чтения файлов журнала, и когда я запускаю банку в Flink (/opt/flink-1.0.3/bin/flink run -m yarn-cluster -yn 2 /home/flink/flink-json-0.1.jar), он успешно обра

1зной

1ответ

Использование Apache Flink и RxJava

В настоящее время я использую флексию Apache и использую RxJava внутри себя, мои вопросы: использование обоих из них подходит? потому что мои операции flink всегда являются функциями карты, и внутри н

0зной

1ответ

Использование потоковой передачи в Hadoop

Я пытаюсь изучить пример this Flink CEP. Я вижу, что в этом примере они создали одно приложение (которое является своего рода потоковым приложением), которое производит &, потребляя данные &, применяя

3зной

2ответ

Apache Flink: Как обрабатываются последние события?

Если элемент прибывает, что нарушает условие водяного знака, как обрабатывается событие? Это выброшено? Или событие все еще распространяется вниз по течению с прошлыми функциями окон, переработанными

1зной

2ответ

Flink on YARN: Amazon S3 неправильно используется вместо HDFS

Я следовал Flink on YARN's setup documentation. Но когда я бег с ./bin/yarn-session.sh -n 2 -jm 1024 -tm 2048, в то же время проверки подлинности Kerberos, я получаю следующее сообщение об ошибке: 201