Flink CDC日志被覆盖了,就是报jdbc connect-timeout,连接不上数据库,连接池创建不了,怎么办? 现在只有了80左右,不是数据库问题,是flink创建连接时出错了,对的,因为是已经有任务在跑了啊,只是再加任务会出现这个问题, 这三个任务是正常的,但再加一个任务就报错了,连不上库,跟sql没关系,如果我关掉其中一个任务,另一个任务就能正常跑,也就是把连接释放出来就能正常。我给一个在sql-client.sh创建的ddl,然后报的错CREATE TABLE mkt_order ( id string, ent_id string, venue_id string, order_no string, order_time timestamp(0), customer_mobile_cipher string, pay_channel int, distribution_channel_type int, distribution_channel_sub_type int, distribution_channel_name string, commodity_cooperative_ticket_id string, creator string, opt_user_id string, order_type int, state int, PRIMARY KEY (id) NOT ENFORCED ) WITH ( 'connector' = 'mysql-cdc', 'server-id' = '7200', 'hostname' = '172.16.54.241', 'port' = '3306', 'username' = 'xxxx', 'password' = 'xxxxx', 'connection.pool.size' = '500', 'database-name' = 'xm_kjg_ticket', 'table-name' = 'mkt_order' ); 创建成功就是sql执行成功,能查询出记录而已,这个是我创建成功,查询的时候报的连不上数据库的错,那太多了,不好发了,情况就是脚本都是可以创建成功的,执行insert的时候创建数据库连接就会报错,使用2.3的话,使用2.2.1不会
那你复现一下,你看下你数据库的最大连接数量是多少,你确定这个ip是对的?还有正常跑的sql 配置,不正常的这个ddl配置,我意思其他创建成功的ddl语句,ddl我只是想看下面的配置,不需要字段,你的集群是不是有两个cdc的包,一个2.2.1 一个2.3,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。