flink logging to file для неработающего кода пользователя

Я новичок в Flink, поэтому этот вопрос может быть довольно простым ...

Версия Flink - 1.5.0.

Я создал образец проекта, скопируйте SocketWindowWordCount из кода примера Flink.

Мой файл pom.xml копируется с официального сайта: здесь

Я просто добавляю некоторые инструкции smiple log.info (...). Независимо от того, я добавляю log4j.properties в папку ресурсов проекта или изменяю log4j-cli.properties в папке flink conf. Добавленный журнал не будет выводиться в файл журнала.

Изменение log4j-cli.properties:

log4j.logger.test.flink=INFO, file, console

После добавления этой строки в log4j-cli.properties я могу видеть журналы в консоли, но все равно не отображаются в обоих jobmanager.log и taskmanager.log.

Я использую flink run для отправки:

flink run -m yarn-cluster -yn=2 test.jar

Цените любую помощь. Благодарю.

logging,apache-flink,

0

Ответов: 1


0 принят

Я нашел местоположение журнала.

На главной странице приложения пряжи: localhost: 8080, щелкните идентификатор приложения, чтобы перейти на страницу обзора приложений, затем нажмите ссылку «Журналы», просто увидите jobmananger.err, jobmananger.log, jobmananger.out, 3 ссылки.

Но мой журнал находится в taskmanager.log. Щелкните ссылку locahost: 8042, чтобы открыть страницу менеджера узлов, затем нажмите «Список контейнеров» в меню слева, затем найдите в списке контейнер taskmanager.log.

каротаж, апач-Flink,
Похожие вопросы