Apache Flink: конфигурация входа в систему игнорируется - PullRequest
0 голосов
/ 28 ноября 2018

У меня есть работа 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 или для журналов приложений?

...