问题一:Flink的LOOKUP JOIN 支持子查询吗?
Flink的LOOKUP JOIN 支持子查询吗?
参考答案:
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610218
问题二:Flink,这两个参数有啥区别呢?
Flink,这两个参数有啥区别呢?
参考答案:
第一个是比较粗一点的表大小粒度,把表分成若干块,进行读取;第二个是比较细一点的表大小粒度,每次抽取表若干条记录读取
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610217
问题三:这个flink-cdc读取OSS归档日志功能,要是用cdc-3.0 平台支持么 ?
这个flink-cdc读取OSS归档日志功能,要是用cdc-3.0 平台支持么 ?
参考答案:
不需要,只需要 VVR 版本支持。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610216
问题四:Flink的holo的io以及cpu使用都还稳定,这块需要如何优化?
sink端busy一直在20%左右 有时候50%
Flink的holo的io以及cpu使用都还稳定,这块需要如何优化?
参考答案:
下面的几种方法试试呢
可以通过调整source并发数来降低sink端的busy。
source并发不要大于上游物理表的分区数或shard数,以防止部分并发空跑和资源浪费。
建议使上游物理表的分区数尽量为source并发的整数倍,以避免数据倾斜问题。
可以查看sink端输出的数据量,通过作业开发页面的更多配置来添加参数pipeline.operator-chaining: 'false',然后启动作业,在sink节点的Records Sent数中查看sink端输出的记录数。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610215
问题五:flink cdc可以读取没有解析之前的binlog么? 我想自己解析
flink cdc可以读取没有解析之前的binlog么? 我想自己解析
参考答案:
这是msyql-cdc的文档,您先看看呢
https://help.aliyun.com/zh/flink/developer-reference/mysql-connector?spm=a2c4g.11186623.0.i36
关于本问题的更多回答可点击进行查看: