问题一:在Flink CDC中启动两个表数据库端磁盘读速率 40M/s ,请问这个有参数可以限制吗?
在Flink CDC中读取oralce 启动一个表的任务,数据库端磁盘读速率 20M/s,启动两个表数据库端磁盘读速率 40M/s ,请问这个有参数可以限制吗?请参考图片:
参考答案:
和源端的负载有关,Oracle cdc占用源端负载还是蛮高,任务没启动时 源端磁盘读的速率很低
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/657793
问题二:在Flink CDC中没看到cdc 3.0包里面需要做什么改动?
在Flink CDC中我目前看到官网上的配置都是flink里面需要做一些修改 但是没看到cdc 3.0包里面需要做什么改动?请参考图片:
参考答案:
对的, 改flink配置,cdc pipeline就相当脚手架.
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/657854
问题三:在Flink CDC中两种消息需要一起收到才可以往下面执行流程。有没有什么好的办法啊?
在Flink CDC中两种消息需要一起收到才可以往下面执行流程。有没有什么好的办法啊?
参考答案:
请参考链接:https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/table/sql/queries/joins/ 。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/657841
问题四:在Flink CDC中发现这两个程序都能消费到,怎么解决呢?
在Flink CDC中相同 topic 和 group.id 两个任务消费,然后向topic发送一条数据,发现这两个程序都能消费到,怎么解决呢?
参考答案:
这不是正确逻辑嘛。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/657833
问题五:在Flink CDC中读取7000万的数据有啥优化措施没,感觉读的好慢?
在Flink CDC中读取7000万的数据有啥优化措施没,感觉读的好慢?
参考答案:
加大并行度,或者全量+增量CDC
关于本问题的更多回答可点击进行查看: