Flink sql 集成hive metastore-测试

櫰木1年前技术文章692

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

相关文章

如何分析IIS占用CPU资源问题?看看这篇文章吧

如何分析IIS占用CPU资源问题?看看这篇文章吧

ProcDump捕获dump文件1、下载官方下载地址为:https://learn.microsoft.com/en-us/sysinternals/downloads/procdump#introd...

Windows自带性能监控工具Perfmon使用介绍

Windows自带性能监控工具Perfmon使用介绍

一、Perfmon简介Perfmon(Performance Monitor)是一款Windows自带的性能监控工具,提供了图表化的系统性能实时监视器、性能日志和警报管理。通过添加性能计数器(Perf...

Redis Sentinel与Cluster安装部署(三)

4.3redis-cluster-resharding重新分配槽1、查看当前集群节点状态信息 # redis-cli --cluster check 172.32.1.59:7000 -a dt20...

Tomcat调优处理

1、隐藏版本号进入tomcat的lib目录找到catalina.jar文件unzip catalina.jar之后会多出两个文件夹 进入org/apache/catalina/util编辑配置文件Se...

切换不同的网络访问同一个业务报错"network error"

切换不同的网络访问同一个业务报错"network error"

问题现象:业务:xxx,使用谷歌浏览器登陆之后,访问“商品档案”模块,会提示“network error”报错内容,但是切换到其他浏览器测试是可以正常访问的,同时,在使用谷歌浏览器访问的情况下,如果切...

在kubernetes中,让某个node成为专属节点

如何让node 去”选择”只有谁(pod)能部署到自身上面?看了下现有的Node Selectors、Node Affinity、Node Taints, 经过比对,发现Node Taints 更适合...

发表评论    

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