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

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

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

展开
收起
cuicuicuic 2023-08-28 15:31:15 96 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版
  • 相关电子书

    更多
    SQL Server在电子商务中的应用与实践 立即下载
    GeoMesa on Spark SQL 立即下载
    原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载