Этот код работает нормально: .keyBy(value -> value.getSessionUid()) но это .keyBy(LogItem::getSessionUid) бросить исключение: Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1 at...

Я пытаюсь настроить Flink 1.2.0 для настройки высокой доступности, и там мне нужно установить параметр, называемый серверной частью состояния. Я ранее устанавливал этот параметр на Rockdb, но затем прочитал документацию, в которой говорится, что для...

Я использую соединитель эластичного поиска flink для отправки данных в индекс эластичного поиска. Но я не могу запустить задание и получить это исключение. Как решить эту проблему? Есть ли какие-либо настройки или конфигурации, которые мне не...

Ссылка на онлайн-руководство по программированию на Python: https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html Я не видел материалов, связанных с потоковым программированием, таких как коннектор kafka и т. д. ....

Я хочу настроить имя задачи на панели управления apache flink. Например, если у нас есть карта задач на панели управления с именем MAP, как я могу изменить ее, чтобы добавить конкретное имя? Большое спасибо.

Можно ли запускать диспетчеры задач Flink на узлах задач AWS EMR? Если да, то чем это отличается от запуска диспетчеров задач на основном узле?

Я использую WordCountProg из учебника на https://www.tutorialspoint.com/apache_flink/apache_flink_creating_application.htm . Код выглядит следующим образом: WordCountProg.java package main.java.spendreport; import...