У меня есть задание flink, в котором я использую логбэк в качестве фреймворка для ведения журнала. Помимо приложений file
, console
, я также использую logstash-logback-appender
для отправки журнала в экземпляр logstash.
Если я запускаю задание flink из Eclipse, журналы отправляются на указанный сервер logstash.
Я могу видеть, что журналы отправляются в logstash, если я упаковываю приложение как jar и запускаю его вне Eclipse.
Однако, если запустить приложение flink как задание (загрузив ту же банку, что и выше) с панели управления flink, журналы не отправляются в logstash.
Моя установка flink выполняется в Windows в соответствии с инструкциями здесь Запускаем флинк на windows. Начинаю мигать с start-cluster.bat
Я думаю, что конфигурация логбэка игнорируется. Я поместил конфигурацию входа в систему в src/main/resources
в моем приложении. Как я могу распознать конфигурацию входа в систему с помощью настройки flink?
Я пробовал шаги, указанные в Лучшие практики. Эти шаги по замене log4j
на logback
предназначены для журналов jobmanager
& taskmanager
или для журналов приложений?