Flink sql 集成hive metastore-测试

櫰木11个月前技术文章393

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

相关文章

Doris集群部署

一、部署Doris集群1.部署doris服务(1)下载Doris            登陆地址https://doris.apache.org/download            选择需要下载的...

k8s Krew 插件使用指南

kubectl Krew 插件使用指南前言:在某些情况下,只是使用 kubectl 命令的时候存在效率比较低、功能不满足的问题,针对这些问题,社区提出了krew插件项目。还有一点是:大部分工程师还是喜...

git常用命令

git status/git status -s查看状态[root@zutuanxue git_data]# git status位于分支 master尚无提交无文件要提交(创建/拷贝文件并使用 "g...

MySQL 8.0 新特性:Instant Add Column

MySQL 8.0 新特性:Instant Add Column

一、前言MySQL 8.0 支持 “快速加列” 功能,既添加字段时可以支持 “INSTANT” 快速完成。通过只修改数据字典的方法来实现大表快速加列,避免之前加列操作必须做的数据拷贝,从而大幅缩小大表...

Trino部署

安装前准备1.1. 创建用户和用户组groupadd trinouseradd -g hadoop trino1.2. 配置环境变量1.2.1. 配置系统环境变量/etc/profileexport...

Trino配置yanagishima-23.0(包含编译)

Trino配置yanagishima-23.0(包含编译)

1 环境介绍1.1 本文采用trino 359yanagishima v23.02 编译yanagishima2.1 安装编译yanagishima需要的工具安装编译yanagishima需要的工具w...

发表评论    

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