apache-flink

1зной

1ответ

flink-streaming-java недоступен в Apache Flink

Я пытаюсь запустить Apache Flink, но получаю ошибку, поскольку зависимость недоступна. Доступен модуль flink-streaming-java. <dependency> <groupId>org.apache.flink</groupId> <artifactId>flin

5зной

2ответ

Apache Flink DataStream API не имеет преобразования mapPartition

Spark DStream имеет mapPartition API, а Flink DataStream API - нет. Есть ли кто-нибудь, кто мог бы объяснить причину. То, что я хочу сделать, - это реализовать API, похожий на Spark reduceByKey на Fli

-1зной

1ответ

Flink Streaming java.lang.Exception: Не удалось загрузить вызывающий класс задачи

Я пытаюсь выполнить базовое потоковое задание Flink (в java) локально. Когда я запускаю свое приложение с использованием eclipse, он работает как шарм. Но когда я бегу через интерфейс Flink командной

1зной

1ответ

Apache Flink fromCollection java.lang.IllegalStateException: данные непрочитанных блок

Я использую Scala и Flink 1,0-SNAPSHOT для выполнения leftOuterJoin на DataSet, и я получаю следующее исключение: 11:54:15,921 INFO org.apache.flink.runtime.taskmanager.Task - CHAIN DataSource (at com

1зной

1ответ

Apache Flink Streaming window WordCount

У меня есть следующий код для подсчета слов из socketTextStream. Необходимы как кумулятивные подсчеты слов, так и подсчет числа окон. У программы есть проблема, что cumulateCounts всегда совпадает с к