flink 连接驱动下载
默认构建的服务只有基础的flink jar包,如果提交的job有用到连接mysql或者使用flink cdc,需要把相应的依赖包加入到jobmanager和taskmanager容器的lib中 可以通过docker cp命令手动添加或在docker-compose.yml中使用挂载
mysql-connector-java-8.0.21.jar
flink-connector-jdbc_2.12-1.14.5.jar
flink-sql-connector-mysql-cdc-2.2.1.jar
#mysql-connector-java的jar包下载
https://dev.mysql.com/downloads/connector/j/
#连接器驱动方法
连接器须要独自下载并放到FLINK_HOME/lib下,可从阿里云镜像点下载相干jar包仓库服务
https://maven.aliyun.com/
https://developer.aliyun.com/mvn/search
#添加MySQL驱动
mysql-connector-java-8.0.16.jar驱动添加到/data/flink/lib/目录下即可
https://cdn.mysql.com//archives/mysql-connector-java-8.0/mysql-connector-java-8.0.29.zip
#flink-connector
下载地址:https://repo1.maven.org/maven2/org/apache/flink/
https://repo1.maven.org/maven2/org/apache/flink/flink-connector-jdbc_2.12/1.14.6/flink-connector-jdbc_2.12-1.14.6.jar
#flink-sql-connector-mysql-cdc
下载地址:https://developer.aliyun.com/mvn/search
https://archiva-maven-storage-prod.oss-cn-beijing.aliyuncs.com/repository/jcenter/com/ververica/flink-sql-connector-mysql-cdc/2.2.1/flink-sql-connector-mysql-cdc-2.2.1.jar?Expires=1679283507&OSSAccessKeyId=LTAIfU51SusnnfCC&Signature=7xiqjbeDhJe9Pui0t9spGt7EsfA%3D