开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC这个因为啥?

Flink CDC这个因为啥?image.png
com.mysql.cj.exceptions.connectionisclosedexception: No operations allowed after connection closed.

展开
收起
真的很搞笑 2023-11-01 14:17:48 59 0
2 条回答
写回答
取消 提交回答
  • 可以尝试按照如下配置文件:

    server:
      port: 8080
    
    spring:
      application:
        name: xxx
      datasource:
        username: xx
        password: xx
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: xxx
        dbcp2:
          test-on-borrow: true
          validation-query: SELECT 1
        hikari:
          max-lifetime: 30000
      jackson:
        date-format: yyyy-MM-dd HH:mm:ss
        time-zone: GMT+8
    
    2023-11-04 08:15:53
    赞同 1 展开评论 打赏
  • 这个错误信息表示MySQL数据库连接被关闭,导致Flink无法从MySQL获取数据。这可能是由于网络问题、MySQL服务器故障或者MySQL连接池的问题导致的。

    以下是一些可能的解决方案:

    1. 检查你的MySQL服务器的状态,确保它正在运行并且可以正常连接。

    2. 检查你的MySQL连接字符串,确保它正确无误。

    3. 增加MySQL连接池的大小,以减少连接竞争的可能性。

    4. 检查你的MySQL服务器防火墙设置,确保Flink可以通过网络连接到MySQL服务器。

    2023-11-02 15:05:06
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

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