1) Невозможно запустить задание Flink с несколькими заданиями (> 500 заданий в одном задании). Получение следующих исключений.
(a) network.partition.PartitionNotFoundException (org.apache.flink.runtime.io.network.partition.PartitionNotFoundException)
(b) rest.handler.taskmanager.TaskManagerDetailsHandler (org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler - Ошибка реализации: необработанное исключение)
(c) исключение кучи памяти
2) Я установил Apache Flink на свой локальный компьютер (Ubuntu 16.04). Разработал java-программы, создал Jar-файлы и пытался запускать их в качестве заданий в веб-интерфейсе Flink. Я могу выполнить задание по отдельности, но не смог запустить несколько заданий параллельно.
Пожалуйста, дайте мне знать, если какая-либо конфигурация должна быть изменена, чтобы я мог запустить их одновременно.
Пожалуйста, дайте мне знать, как их преодолеть и какие настройки необходимы для запуска задания.
Пытался увеличить память до 2048.