Удаленная отладка Flink локального кластера

Question

Я хочу развернуть мои задания в локальном кластере Flink во время разработки (т. Е. JobManager и TaskManager, работающие на моем ноутбуке для разработки) и использовать удаленную отладку. Я пытался добавить "-agentlib: jdwp = transport = dt_socket, server = y, suspend = y, address = 5005" в файл flink-conf.yaml. Поскольку диспетчер заданий и задач выполняется на одном компьютере, диспетчер задач создает исключение, указывающее, что сокет уже используется, и завершает работу. Есть ли способ, которым я могу это запустить.

Answer 1

Возможно, вы устанавливаете env.java.opts, что влияет на все JVM, запущенные Flink. Поскольку диспетчер заданий запускается первым, он захватывает порт до запуска диспетчера задач.

Вы можете использовать env.java.opts.taskmanager для передачи параметров только для JVM диспетчера задач.