问题一:Flink CDC这个过程的速度主要跟什么因素有关啊?
Flink CDC这个过程的速度主要跟什么因素有关啊?
而且为什么越来越慢了
参考回答:
Flink CDC 的速度受多种因素影响,包括但不限于:
- 输入源数据量:大量的输入数据会降低 Flink CDC 的速度。
- 数据解析和处理:处理复杂的转换和聚合会降低 Flink CDC 的速度。
- 机器资源:CPU、内存等资源不足会降低 Flink CDC 的速度。
- 并发度:提高并发度有助于提高 Flink CDC 的速度。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566223
问题二:Flink CDC这个是什么问题?
Flink CDC这个是什么问题?flink-1.15
参考回答:
测试sr和doris查询速度,a表66674858数据,b表219数据,c表2787数据,三张表关联查询,包含模糊查询,union,嵌套子查询等等条件,sr 2.6秒到2.8秒上下,doris 3.1秒到3.5秒上下 测试版本starrocks3.1.2 doris2.0.2
我看了官方的flink没有error_code这个字段
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566222
问题三:flink cdc 2.4.1 数据源设置启动模式:这个是什么地方设置问题导致的?
flink cdc 2.4.1 数据源设置启动模式:StartupOptions.initial(),并配置了本地存储的checkpoint ,但是springboot服务每次启动打印显示都是表里的全部数据 这个是什么地方设置问题导致的?
参考回答:
springboot不要和flink搞在一起,到处是i坑,比如你现在就是给你自己挖坑,StartupOptions.initial() 默认是就是全量数据,每次启动都是,除非你启动的时候指定了上次的checkpoint的快照,从checkpoint启动
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566221
问题四:Flink CDC2.4版本 sqlserver有增量连接器,看官网介绍很少,具体有哪些好处啊?
Flink CDC2.4版本 sqlserver有增量连接器,看官网介绍很少,具体有哪些好处啊?
参考回答:
增量并行无锁读取,加快source的读取时间
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566219
问题五:Flink CDC写入oracle 总是锁表有人遇到过吗?
Flink CDC写入oracle 总是锁表有人遇到过吗?
参考回答:
2.4版本oracle增量快照不锁表
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/566218