Мы пытаемся построить Flink Job для агрегирования цен с довольно сложной логикой.
Например. в предыдущей версии был график, как показано ниже.
После очередной итерации разработки я добавил к работе еще больше сложности. Новая версия отлично работала в среде IDE, однако развертывание в кластере завершилось ошибкой с
Вызвано: org.apache.flink.runtime.client.JobClientActorSubmissionTimeoutException: время отправки задания в JobManager истекло.
Если я перенастрою задание (уменьшу сложность графа), оно будет развернуто без каких-либо проблем.
Мои вопросы:
- Существуют ли какие-либо ограничения на размер и сложность графика заданий при отправке в автономный кластер?
- Есть ли возможность отключить графическое представление графа (у меня есть подозрения, что проблема вызвана графическим представлением - локально моя работа работает)
- Существуют ли какие-либо инструменты отладки, чтобы понять, что происходит при отправке задания и почему время ожидания истекает?
Заранее спасибо.
