问题一:Flink CDC sql采集mysql能拿到before的数据吗?
Flink CDC sql采集mysql能拿到before的数据吗?
参考答案:
可以,json 去拿 before 这个key
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584569
问题二:Flink CDC这个issue能提交嘛 ?
Flink CDC这个issue能提交嘛 ?
https://github.com/ververica/flink-cdc-connectors/issues/2930
参考答案:
https://github.com/ververica/flink-cdc-connectors/issues/2934
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584564
问题三:Flink CDC最低可以设置为多少呢?
Flink CDC最低可以设置为多少呢?
参考答案:
connection.pool.size,即可以限制连接池的数据量。connection.pool.size默认连接20个。最小是2。
——参考来源于阿里云官方文档。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584562
问题四:Flink CDC1.17.1 cdc 2.4.2 的连接方式改变了吗?
Flink CDC1.17.1 cdc 2.4.2 的连接方式改变了吗,跑三四个任务的时候 后面的任务就会报这些,是cdc的有连接池配置 还是数据库里的活跃线程不够呢?
参考答案:
你看下你连接池参数,cdc source有的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/584560
问题五:Flink CDC从Kafka中消费数据Flink读取出来的却是null值怎么回事呢?
Flink CDC从Kafka中消费数据,然而Kafka中有数据,但是Flink读取出来的却是null值。这些数据来自MySQL,我是通过Maxwell将其同步到Kafka中的,怎么回事呢?
参考答案:
Flink初始化读取的是正确的,增量是不正确的,增量也会有默认值,源头为null,初始化肯定为null
关于本问题的更多回答可点击进行查看: