Я использую следующий скрипт для отправки приложения flink,
flink run -m yarn-cluster -c com.my.flink.learningflink.FlinkToMySQL -yn 4 -ys 1 -j /tmp/learing.flink.1.7.1-0.1.jar
Мой класс FlinkToMySQL находится в learing.flink.1.7.1-0.1.jar, но мое приложение также нуждается взависеть от mysql jar, как я могу указать mysql jar и другие зависимые jar.
Кроме того, я пробовал опцию -yt
со следующим скриптом
flink run -m yarn-cluster -c com.my.flink.learningflink.FlinkToMySQL -yn 4 -ys 1 -yt /tmp/mysql-connector-java-5.1.45.jar -j /tmp/learing.flink.1.7.1-0.1.jar
все еще жалуется, что не найден подходящий драйвер (он хорошо работает в моей локальной IDE).
Спасибо.