当前位置:网站首页>How to test SQL of Flink? You can't use jar test every time, so sqk client comes
How to test SQL of Flink? You can't use jar test every time, so sqk client comes
2022-07-18 04:04:00 【Vegetarian husky】
flink Of sql test , How to test
The link of the official website can be viewed directly ( The Chinese version is safe to eat )
How to open flink Of sql Client side test
First of all to flink Of bin Under the table of contents
/opt/flink-1.15.0/bin
And then execute ./sql-client.sh
./sql-client.sh embedded
Then the following figure will appear , That means the startup was successful 
Paste the previous statement
create table source
create table t_shh_source(name String) WITH ( 'connector' = 'jdbc','url' = 'jdbc:mysql://192.168.1.91:3306/test','table-name' = 't_shh_source', 'username' = 'root', 'password' = 'dk123456','driver' = 'com.mysql.cj.jdbc.Driver');
create table target
create table t_shh_target(name String) WITH ('connector' = 'jdbc','url' = 'jdbc:mysql://192.168.1.91:3306/test','table-name' = 't_shh_target', 'username' = 'root','password' = 'dk123456','driver' = 'com.mysql.cj.jdbc.Driver');
DDL
insert into t_shh_target select name from t_shh_source;
flink Of web The page is displayed successfully

边栏推荐
- Change Buffer介绍
- On the difference and use of hash and history
- ant-desgin 打開pdf增加認證參數據
- Implementation of ZABBIX proxy active mode
- ant-desgin 打开pdf增加认证参数据
- flink的yarn集群方式(2)
- 关于hash和history的区别和使用
- 是时候升级你的Junit了,Junit5超详细实战
- Serial port communication of esp32 (in the form of interruption and watchdog)
- Lingyun going to sea | Lianlian International & Huawei cloud: building a cross-border e-commerce digital service network
猜你喜欢

模糊测试的简介

OSPF—不规则区域、LSA

OSPF experiment in mGRE environment

Implementation of ZABBIX proxy active mode

My creation anniversary

关于hash和history的区别和使用

Speed of light raised more than $7billion miqun: increase the proportion of green technology and hard technology investment

Is it true that double non undergraduate students cannot enter the big factory? Ali technology four sides + cross face +hr face, successfully got the offer!!

Source code analysis (personal collection, not standard)

布局元宇宙社交,数字经济将迎来发展新机遇
随机推荐
LeetCode刷题
Ant begin opens PDF to add authentication parameter data
Quickly deploy mqtt clusters on Alibaba cloud using terraform
[openfoam pre school preparation 3 - install openfoam-v8]
Google Earth engine (GEE) -- abnormal value of S2 image
OpenHarmony藏头诗应用
vulnhub Funbox: 1
UNP学习笔记-第三章套接字编程
非常全面的IReport的使用
Explore NTP clock synchronization (PTP time synchronization) of intelligent driving interval speed measurement
OSPF—不规则区域、LSA
Flowable end eventendevent custom attribute
MGRE与OSPF
AI briefing - model integration Sam and SWA
Change Buffer介绍
T40N智能视频应用处理器-电池摄像机SOC
Arkui FAQ summary [Series 1]
进程间通信——共享内存
Unp learning notes - Chapter 2 transport layer
ZCMU--1099: 查找元素II