У меня есть программа, которая отлично работает в локальном кластере, но не работает должным образом при выполнении на удаленном кластере. Я хотел бы знать, каковы наилучшие и распространенные способы отладки программы, работающей на удаленном кластере Flink? Любая помощь приветствуется!Отладка на удаленном кластере
Существует несколько способов отладки приложения Flink на удаленном кластере. Поскольку использование реального отладчика затруднено, я сначала попытался бы как можно больше зайти, чтобы узнать об ошибке.
Другим подходом, который может быть полезен, является использование аккумуляторов Flink. С их помощью вы можете собрать некоторую статистику: например, когда у вас есть фильтр, вы можете определить, сколько элементов прошло фильтр и так далее.
Последнее средство добавляет отладчик в один из JVM Flink TaskManager.
Также ознакомьтесь с моей презентацией на тему: http://de.slideshare.net/robertmetzger1/apache-flink-hands-on