开发者社区 > 大数据与机器学习 > 正文

Flink CDC日志被覆盖了,就是报jdbc connect-timeout,连接不上数据库,?

Flink CDC日志被覆盖了,就是报jdbc connect-timeout,连接不上数据库,连接池创建不了,怎么办?image.png image.png image.png 现在只有了80左右,不是数据库问题,是flink创建连接时出错了,对的,因为是已经有任务在跑了啊,只是再加任务会出现这个问题,image.png 这三个任务是正常的,但再加一个任务就报错了,连不上库,跟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' );image.png 创建成功就是sql执行成功,能查询出记录而已,这个是我创建成功,查询的时候报的连不上数据库的错,那太多了,不好发了,情况就是脚本都是可以创建成功的,执行insert的时候创建数据库连接就会报错,使用2.3的话,使用2.2.1不会

展开
收起
真的很搞笑 2023-05-29 13:43:50 163 0
1 条回答
写回答
取消 提交回答
  • 那你复现一下,你看下你数据库的最大连接数量是多少,你确定这个ip是对的?还有正常跑的sql 配置,不正常的这个ddl配置,我意思其他创建成功的ddl语句,ddl我只是想看下面的配置,不需要字段,你的集群是不是有两个cdc的包,一个2.2.1 一个2.3,此回答整理自钉群“Flink CDC 社区”

    2023-05-29 13:58:16
    赞同 展开评论 打赏

大数据领域前沿技术分享与交流,这里不止有技术干货、学习心得、企业实践、社区活动,还有未来。

相关产品

  • 实时计算 Flink版
  • 日志服务
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载