logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Flink之SQL client使用案例

s(--slots):每个TaskManager的slot数量,默认一个slot一个core,默认每个taskmanager的slot的个数为1,有时可以多一些taskmanager,做冗余。# 在提交n次事务后,进行binlog的落盘,0为不进行强行的刷新操作,而是由文件系统控制刷新日志文件,如果是在线交易和账有>关的数据建议设置成1,如果是其他数据可以保持为0即可。所以该错误可以忽略。Per-

文章图片
#flink#sql#大数据 +1
SQL之行列转置以及非常规的行列转置

创建数据表# 插入数据values ('张三', '语文', 80),('张三', '数学', 90),('张三', '物理', 85),('李四', '语文', 85),('李四', '数学', 92),('李四', '物理', 82);

文章图片
#sql#数据库
Kafka操作

--replication-factor 指定分区中的副本数量 默认一个。- --describe --topic itcast 查看某个主题详情信息。- --bootstrap-server 指定连接的kafka服务。- --bootstrap-server 指定连接的kafka服务。- --bootstrap-server 指定连接的kafka服务。---bootstrap-server 指定

文章图片
#kafka#分布式
到底了