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

想问问 Flink CDC 中 flink sql是不生效吗?

想问问 Flink CDC 中 connection.pool.size参数 在flink sql是不生效吗?

展开
收起
真的很搞笑 2023-08-28 15:31:15 157 0
1 条回答
写回答
取消 提交回答
  • 在 Flink CDC 中,connection.pool.size 参数是用来配置连接池的大小,用于管理与数据库的连接。然而,在 Flink SQL 中,该参数并不直接生效。

    Flink CDC 是一个用于实时数据变更捕获的库,它提供了与 Flink SQL 集成的功能。当使用 Flink SQL 进行 CDC 任务的配置时,Flink SQL 的连接管理是由底层的 Flink Runtime 来处理的,而不是直接由 CDC 组件处理。

    对于 Flink SQL 中的连接管理,可以通过 Flink 的配置参数来进行调整。具体来说,可以考虑调整以下两个参数:

    table.exec.resource.default.parallelism:该参数定义了 Flink SQL 中默认的并行度。通过适当增加并行度,可以提高连接的并发数,间接增加连接池的大小。

    execution.max-parallelism:该参数定义了 Flink 作业中最大的并行度。通过适当调整并行度的上限,可以为连接分配更多的资源。

    2023-09-18 18:02:33
    赞同 展开评论 打赏

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

相关产品

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

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