Как отлаживать Apache Flink?

Question

Я работаю над расширением API Apache Flink Python, чтобы лучше соответствовать API Java, и я получаю странные ошибки о типах данных, над которыми я работаю. Есть ли способ подключить отладчик Java (например, Intellij IDEA) для отладки самого Flink?

Answer 1

Благодаря Svetlin Zarev для указания удаленной отладки Java. Вот некоторые полезные вещи, которые я должен был найти перед тем, как задать вопрос:

1. Настройка удаленной отладки в IDE/отладчике/независимо от того, например. для IntelliJ IDEA
2. аргументов Изменить Apache Flink JVM по setting env.java.opts in the configuration, используя соответствующие настройки для удаленной отладки

Или отлаживать FLiNK бегуны работы, настроить удаленную отладку и запуск задания с помощью bin/flink с JVM_ARGS набором в вашей среде. Обязательно установите JVM_ARGS только для bin/flink, а не для менеджера заданий Flink (т. Е. bin/start-local.sh) или порты будут сталкиваться.

Я сделал небольшую функцию оболочки рыбы, которая завершает работу задания Flink, чтобы установить правильные аргументы here.