问题一:FlinkCDC源表为oracle表时,使用initial方式全量同步时,只同步过来一条数据
FlinkCDC源表为oracle表时,目标表也是oracle表,使用initial方式全量同步时,只同步过来一条数据,其实源表有很多条数据,请问是因为啥呢?
参考答案:
FlinkCDC在进行全量同步时只同步了源表的一条数据,可能的原因有以下几点:
- 配置问题:确保在初始化同步阶段正确配置了全量数据抽取的方法,比如通过某个时间点或者SCN号来进行全量数据读取。
- 连接/权限问题:检查Flink CDC连接到Oracle数据库的用户是否有足够的权限查看和读取源表的所有数据。
- SQL筛选条件:确认在数据同步过程中没有误加了限制条件,导致只同步了一条记录。
- 程序逻辑错误:检查Flink CDC作业的代码或配置,是否在处理全量数据时出现了提前结束或者其他逻辑错误。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/604660
问题二:Flink cdc3.0 支持变化的表和多张维表 join 了吗?
Flink cdc3.0 支持变化的表和多张维表 join 了吗?
参考答案:
历史数据,考虑状态的话,那就维表join,不走多流join。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/604652
问题三:Flink CDC3.0增量读取source时候,sink可以根据并行度生效,可以做到这个效果不?
Flink CDC3.0增量读取source时候,sink可以根据并行度生效,以表单位或者其他特性分发到其他taskmanager了吗?
参考答案:
可以。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/604651
问题四:Flink这个哪里有关闭按钮?
Flink这个哪里有关闭按钮?
参考答案:
这里
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/603873
问题五:Flink cdc支持同步自建的ES吗 ?
Flink cdc支持同步自建的ES吗 ?
参考答案:
不支持,ES都不支持。
关于本问题的更多回答可点击进行查看: