Flink sql 集成hive metastore-测试
FQA
1、如何不使用catalog命令,默认进入hive catalog
在sql-client-defaults.yaml中添加以下配置
2、如何使用mysql
使用./bin/sql-client.sh 进入shell 执行以下sql,将mysql 表注册到flink
参考文档:https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/jdbc/
CREATE TABLE user1 ( id int ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://172.16.104.165:30066/test', 'table-name' = 'user', 'username' = 'root', 'password' = '123456' );