Flink sql 集成hive metastore-测试

櫰木1年前技术文章523

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

相关文章

Hudi集成Spark

Hudi集成Spark

环境准备安装Spark1)Hudi支持的Spark版本HudiSupported Spark 3 version0.12.x3.3.x,3.2.x,3.1.x0.11.x3.2.x(default b...

PG的多版本并发控制(一)

PG的多版本并发控制(一)

一、 表系统字段几个比较重要概念1.1  tupletuple表示表中的数据行,在MySQL中用row表示。在表数据页中,主要分为普通的数据元祖和TOAST元祖。以下是一个普通数据元祖的结构,主要由三...

企业级大数据安全架构(八)

企业级大数据安全架构(八)

前面第七章详细介绍了部署FreeIPA来做kerberos认证,这节接着介绍FreeIPA高可用部署1.FreeIPA高可用配置说明:在安装完一台ipa-server之后,在另一个备份节点部署ipa-...

企业级大数据安全架构(三)

企业级大数据安全架构(三)

一、Ambair修改集群节点hostname在后面安装FreeIPA,需要机器名带全域名,如果我们之前集群节点机器名不是全域名可以按照下面方法在Ambari上修改所有节点机器名1.部署节点说明本次测试...

Kubernetes openelb

1、背景在云服务环境中的 Kubernetes 集群里,通常可以用云服务提供商提供的负载均衡服务来暴露 Service,但是在本地没办法这样操作。而 OpenELB 可以让用户在裸金属服务器、边缘以及...

Ranger部署

安装前准备1.1. 创建用户和用户组groupadd rangeruseradd -g ranger ranger1.2. 数据库配置mysql -uroot -p -hxxx.xxx.xxx.13 ...

发表评论    

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