У меня есть программа flink, где некоторая логика преобразования исходит из определяемой пользователем лямбда-функции. Я должен выполнить пользовательский код во время выполнения, загрузив jar и метод invoke. Я попытался использовать URLClassLoader, чтобы добавить банку программно. Это прекрасно работает, когда я бегу в Intellij. Но когда тот же код выполняется в кластере Flink Standalone, динамически загружаемый класс не работает. Я получаю исключение ClassNotFound. Как я могу исправить эту проблему.
Примечание: я не могу упаковать пользовательский jar как образ jab и не могу добавить его в директорию / lib. Есть ли другой возможный способ добиться динамической загрузки классов.