flink连接驱动下载

韵味老鸟 2024-07-28 14:50:36

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

0 阅读:10