Как выполнить flink задание удаленно, когда jink задание громоздко

Question

У меня есть сервер Flink, работающий в кластере Kubernetes. У меня есть фляга работы, которая является громоздкой из-за продукта и сторонних зависимостей. Я запускаю это через ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment (хост, порт, jar); Размер банки составляет около 130 МБ после оптимизации. Я хочу вызвать remoteExecution без загрузки JAR-файла, чтобы загрузка не происходила каждый раз, когда необходимо выполнить задание. Есть ли способ загрузить банку один раз и вызвать ее удаленно, не упоминая банку (в java)?

Answer 1

Вы можете развернуть на кластер заданий в Kubernetes . Это отправит ваш пользовательский код jar вместе с двоичными файлами Flink в ваш кластер Kubernetes. Недостатком является то, что вы не можете изменить задание после перезапуска кластера Flink.