在Flink CDC中cdc 去接postgrep 分库分表,需要分别给分数据库创建source吗?
在Flink CDC中cdc 去接postgrep 分库分表,需要分别给分数据库创建source吗?
flink-cd写source语句的时候,可以连接postgresql数据库的插槽集吗
现状:目前一个任务一个插槽,但是随着任务量的增大,插槽数量也会增大,还会去更改postgresql的配置max_replication_slots,数量更改到太大会影响数据库的使用,索性建了postgresql的插槽集 CREATE PUBLICATION alltables FOR ALL TABLES; 但是flink cdc的语句中是使用slot.name去连接插槽,会自动创建一个插槽,.....
Flink CDC中报线程池问题 我把source表的调到100 也是数据库限制了吗?
Flink CDC中报线程池问题 我把source表的调到100 也是数据库限制了吗?
OceanBase数据库中使用source命令导入sql会中断是怎么回事?
"OceanBase数据库中使用source命令导入sql会中断是怎么回事?并且中断后必须重启observer才可以,问题出在哪里?就是使用source导入sql 文件,文件大小100多兆,但是导入部分就中段了。"
问下各位大佬,你们拿到cdc的source消息后是怎么处理的?是在process里面连接目的数据库还
问下各位大佬,你们拿到cdc的source消息后是怎么处理的?是在process里面连接目的数据库还是另外写一个sink?
请问一下,flink里面能不能写多个这样的source,是同一个数据库,多个database 只是目
请问一下,flink里面能不能写多个这样的source,是同一个数据库,多个database 只是目前不提供一个账号能同时访问这么多个库试了一下好像只能写一个
source 导入数据库有这个报错呐?
]Failed to execute the DDL task. Caused by: Failed to SYNC to the following nodes
source 导入数据库有这个报错呐
]Failed to execute the DDL task. Caused by: Failed to SYNC to the following nodes
Seata中at source是数据库 如果并发比较高 数据库扛不住怎么办呢?
Seata中at source是数据库 如果并发比较高 数据库扛不住怎么办呢?
同一个作业有两个source,同一链接不同数据库账号,为何第二个链接查出来的数据库列表是第一个账号的
同一个作业有两个source,同一链接不同数据库账号,为何第二个链接查出来的数据库列表是第一个账号的
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。