моргнуть на кубернетес загрузить внешние баночки в кластер

Question

Я развертываю кластер flink на kubernetes (Session Cluster), и я хотел знать, есть ли какая-либо конфигурация (на flink-conf.yaml), для которой я буду загружать внешние jar в кластер.

Насколько я знаю, flink загрузит все jar-файлы в lib / folder, но, скажем, я хочу загрузить jar для метрик, и я не хочу помещать его вручную в папку lib (потому что при каждом развертывании он будет его удалять), и я не хочу делать make lib / folder a mount.

Я хочу создать библиотеку / mnt / external-jars (которая будет монтировать), и flink загрузит в ее classpath все jar-файлы внутри этого каталога. .

Возможно ли это как-то?

Answer 1

Вы можете использовать опцию конфигурации pipeline.classpaths, которая принимает разделенный точкой с запятой список путей к классам. Этот параметр конфигурации читается при запуске клиента Flink. Пути к классам будут добавлены к сгенерированному Flink JobGraph перед его отправкой в ​​кластер. Обратите внимание, что пути к классам должны быть доступны с узлов кластера.

pipeline.classpaths: file:///mnt/external-jars/MyJar.jar;file:///foobar/other-jars/MyJar2.jar