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