Flink sql 集成hive metastore-测试

櫰木2年前技术文章927

FQA

1、如何不使用catalog命令,默认进入hive catalog

在sql-client-defaults.yaml中添加以下配置

image.png

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'
);

相关文章

大数据集群部署规划(二)硬件配置要求

CPU(虚拟机建议配置*2)X86服务器:最低配置:双路4核Intel处理器。推荐配置:双路8核Intel处理器。ARM服务器:双路32核ARM处理器Bit-mode64位内存(虚拟机不建议超分)物理...

 Atlas架构与原理

Atlas架构与原理

一、总体架构Atlas 是一个可伸缩且功能丰富的数据管理系统,深度集成了 Hadoop 大数据组件。简单理解就是一个 跟 Hadoop 关系紧密的,可以用来做元数据管理的一个系统,整个结构图如下所示:...

Doris审计插件的安装

Doris审计插件的安装

插件下载地址:https://doris.apache.org/download1.安装Doris审计插件(1)解压 Audit Loader 插件步骤1. 复制插件文件cp  /opt/dtstac...

HDFS核心参数

HDFS核心参数

1.NameNode内存生产配置(1)NameNode内存计算,每个文件块大概占用150byte,一台服务器128G内存为例,能存储9.1亿个文件128 * 1024 * 1024 * 1024  /...

kafka开启kerberos和ACL

kafka开启kerberos和ACL

kafka开启kerberos和ACL一、部署kafka-KB包1.上传软件包依次点击 部署中心----部署组件----上传软件包选择需要升级的kafka版本并点击确定 2.部署kafka依次点击部署...

linux中的buffer和cache

linux中的buffer和cache

linux中的buffer和cache一、buffer和cache的来源及应用1、来源Buffer 是缓冲区,而 Cache 是缓存,两者都是数据在内存中的临时存储。那么,这两种“临时存储”有什么区别...

发表评论    

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。