Flink Logging не работает в кластерном режиме - PullRequest
0 голосов
/ 05 августа 2020

Недавно я столкнулся с проблемой в Flink Logging в автономном кластерном режиме при использовании logback. xml в качестве журнала. Мое требование состоит в том, что все мои задания должны регистрироваться в конкретной папке, а журналы моей инфраструктуры flink должны быть помещены в отдельную папку, а также для каждого задания, выполняемого в моем кластере flink, должна быть отдельная папка для разных заданий. Я протестировал его в своем локальном кластере, который работает нормально, и я получаю все свои журналы, отдельные папки, соответствующие моему заданию Flink, но как только я развертываю свой код в автономном кластере вместе с соответствующим логбэком. xml для каждого задания, которое он не выполняет. т журналов вообще. Я также сослался на следующее. ссылка на мой запрос, но все же я застрял с проблемой.

Ограничение ведения журнала Flink: Как передать конфигурацию журнала в задание flink

1 Ответ

0 голосов
/ 06 августа 2020

Не могли бы вы указать, где находится ваш файл журнала? Согласно документации flink, это должно быть указано явно, установив свойство среды -Dlogback.configurationFile=<file> или поместив logback. xml в путь к классам - обычно я переопределяю тот, который находится в каталоге flink/conf.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...