Apache Flink: конфигурация логбэка игнорируется

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


person tweeper    schedule 28.11.2018    source источник
comment
У меня похожая ситуация, не могли бы вы подсказать, как вы решили эту проблему?   -  person Apollo    schedule 29.02.2020


Ответы (1)


Попробуйте добавить библиотеку logstash-logback-encoder в папку lib / вместе с банками logback.

person user3788005    schedule 05.11.2019