Как добавить зависимость в кластере миникуб флинк?

Question

У меня есть jar задания, который зависит от flink-json-1.7.2.jar, flink-table_2.11-1.7.2.jar.Это нормально работает на моей локальной машине, если я добавлю эти два jar-файла в папку lib flink.Как я могу добиться того же на моем кластере Minikube.т.е. добавить зависимости, чтобы мигать.Ps.Я настроил свой миникуб, следуя этой документации.

Также я вижу, как эти банки добавляются в толстый сосуд, созданный при создании банка заданий.

Answer 1

Поскольку вы внедрили задание Flink на локальном компьютере, я предполагаю, что возможно создать свой собственный собственный образ Docker и включить туда запрошенные * .jar-файлы, как описано здесь .Хотя вы уже загрузили кластер minikube Kubernetes, настроенный образ Docker можно использовать в соответствующем задании Flink Файлы развертывания Kubernetes.

Answer 2

Из-за проблемы в Apache Calcite, которая препятствует сборке мусора пользовательскими загрузчиками классов, мы не рекомендуем создавать fat-jar, включающий зависимость flink-table.Вместо этого мы рекомендуем настроить Flink для включения зависимости flink-table в системный загрузчик классов.Это можно сделать, скопировав файл flink-table.jar из папки ./opt в папку ./lib.

ОТ документов