Интересно, есть ли у кого-нибудь опыт с пометкой рыбы? * Выполняется партия Flink.
* Подобно тому, как можно пометить рыбу и отслеживать ее движение, отмечая события журнала общим тегом или набором.элементов данных позволяет отслеживать весь поток транзакции или запроса.Мы называем это Fish Tagging.
source
В частности, я хотел бы убедиться, что идентификатор партии добавляется в каждую строку журнала, которая имеетчто-нибудь делать с этим конкретным пакетным выполнением.Это позволит мне отслеживать партии в Kibana
Я не вижу, как использование log4j MDC будет распространяться через несколько узлов Flink и использование поиск системных свойств для ввода идентификатора через параметры виртуальной машины не позволил бы мне запускать пакеты одновременно (не так ли?)
Заранее спасибо за любые указатели