Как изменить уровень регистрации отдельного приложения в автономном кластере FLINK

Question

В автономном кластере Flink в кластере запущено много приложений.

Как вы знаете, диспетчер задач и все приложения работают в одиночном jvm в автономном режиме, как изменить уровень ведения журнала приложения, не влияя на уровень ведения журнала других приложений.

На глобальном уровне диспетчера задач можно изменить уровень ведения журнала, но при этом будет изменено ведение журнала для всех приложений, работающих в кластере, кроме этого потребуется также перезапуск всего диспетчера задач, что не является хорошей идеей в все.

Answer 1

Как правило, невозможно определить разные уровни журнала для разных заданий, выполняющихся в одном кластере Flink, относительно классов кластера. Проблема заключается в том, что классы кластера являются общими для всех заданий и, таким образом, используют один и тот же уровень журнала. Что вы можете сделать, это определить различные уровни журналов для ваших классов работы путем правильной настройки log4j.properties:

log4j.logger.my.app1=DEBUG
log4j.logger.my.app2=WARN
log4j.logger.my.app3=OFF

При использовании log4j 2 вы также можете включить интервал периодического обновления для файла log4j.properties. Эта функция позволяет вам изменять файл свойств, и log4j сам перенастраивается по отношению к интервалу обновления.