Когда я запускаю автономный кластер flink, он регистрирует журналы демона в файле, упомянутом в файле conf / log4j.properties, и когда я отправляю задание flink в этом кластере, он использует тот же файл свойств для регистрации журналов приложения и записи в тот же файл журнала диспетчеров задач. Я хочу иметь отдельные файлы журналов для каждого моего приложения, представленного в этом автономном кластере flink. Есть ли способ добиться этого?
Как указать файл журнала, отличный от файла журнала демона, при отправке задания flink в автономном кластере flink
Ответы (1)
Когда вы отправляете задание с помощью сценария оболочки ./bin/flink, используйте следующие переменные среды для управления расположением файла журнала:
- FLINK_LOG_DIR указывает каталог, в котором будет отображаться журнал
- FLINK_IDENT_STRING позволяет сделать имя файла уникальным
Например, если вы начинаете свою работу с
FLINK_LOG_DIR=/var/log FLINK_IDENT_STRING=my_app_id ./bin/flink run /path/to/the.jar
тогда журналы появятся в /var/log/flink-my_app_id-client-$HOSTNAME.log
Обратите внимание, что это применимо только к сообщениям, которые регистрируются через фреймворки журналирования, а не к вещам, которые просто выводятся на стандартный вывод.
person
Community
schedule
08.11.2016
Это будет обслуживать только журналы на стороне клиента, а не приложение, работающее в кластере. Любое другое решение, пожалуйста.
- person Anand Shaw; 09.11.2016
Для меня при использовании локального кластера flink он создает правильные файлы журнала и записывает в него некоторые сообщения, однако большинство сообщений по-прежнему записываются в журнал по умолчанию, поэтому все задания по-прежнему переходят в журнал по умолчанию. Я не знаю, почему это происходит, потому что мой logback.xml содержит регистратор для
de.mydomain.myapp, а de.mydomain.myapp.something переходит в отдельный журнал, а de.mydomain.myapp.somethingelse переходит в журнал по умолчанию.
- person user826955; 03.04.2019
