请教一下,一个 Flink SQL里面,要写入 两张 Sink 表(比如都是写到 dbtest 这个数据库下),那么这个数据库的连接 是共用一个 还是 两个?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
Flink SQL 使用 Flink SQL 连接池来管理数据库连接。每次创建一个连接时,Flink SQL 会从连接池中获取一个连接。如果连接池中没有可用的连接,Flink SQL 会创建一个新的连接。
在您的示例中,如果两个 Sink 表都写入 dbtest 数据库,那么 Flink SQL 会使用同一个连接池来管理这两个连接。
以下是 Flink SQL 连接池的配置:
flink.sql.connector.jdbc.connection.pool.size = 10
该配置指定了连接池的大小。连接池的大小表示连接池中可以存储的最大连接数。如果连接池中的连接都被使用了,Flink SQL 会创建一个新的连接。
您可以根据需要调整连接池的大小。如果您的应用程序需要大量的连接,您可以增加连接池的大小。如果您的应用程序不需要大量的连接,您可以减少连接池的大小。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。