Я пишу пакетное задание с Apache Flink, используя DataSet API. Я могу прочитать текстовый файл,...
Мы выполняем пакетное задание на flink, которое считывает данные из GCS и выполняет некоторую...
Я использую Apache Flink 1.9.1 на Apache Mesos 1.8.1, используя более или менее стандартные...
Код ниже работает локально, но не в кластере. Он зависает на GroupReduceFunction и не завершается...