需要额外下载jar包:
mysql-connector-java-8.0.20.jar
flink-connector-jdbc_2.11-1.12.0.jar
下载之后将jar放入到flink-1.12.0/lib下
下载地址:https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/table/connectors/jdbc.html
启动flink集群
bin/start-cluster.sh
启动Flink sql客户端
bin/sql-client.sh embedded
编写创建表脚本测试
CREATE TABLE t_info_sjy (
id VARCHAR,
sjylx VARCHAR,
url VARCHAR,
port VARCHAR
) WITH (
'connector.type' = 'jdbc',
'connector.url' = 'jdbc:mysql://192.168.30.118:3306/jhpt?serverTimezone=UTC&characterEncoding=utf8&useUnicode=true&useSSL=false',
'connector.table' = 't_info_sjy',
'connector.driver' = 'com.mysql.cj.jdbc.Driver',
'connector.username' = 'root',
'connector.password' = 'root',
'connector.lookup.cache.max-rows' = '5000',
'connector.lookup.cache.ttl' = '10min'
);
select * from t_info_sjy;
查看结果
最后修改于 2021-04-15 17:27:10