Хорошо, после некоторых исследований я нашел причину. Просто отправьте сюда, если в эту проблему есть кто-то другой.
Метод addJar()
не добавляет баночки в путь класса драйвера. То, что делает этот метод, - это найти банки в узле драйвера, распределить на рабочие узлы и затем добавить путь к классам исполнителей. Поскольку я отправляю свое искровое задание в локальном режиме, путь класса драйвера (я думаю) используется в искровом задании, баны, добавленные методом addJar()
, не могут быть найдены.
Чтобы решить эту проблему, используйте параметр --jars
, чтобы включить все банки при отправке искрового задания или использовать --driver-class-path
для добавления баннеров. Более подробную информацию можно найти здесь здесь .