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