flink mongo cdc 报这个错，有大佬遇到过吗？
flink mongo cdc 报这个错，有大佬遇到过吗？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
Flink Mongo CDC 报错 com.mongodb.client.MongoException: [MongoInternalException: Exception in MongoClient.create(MongoClient.java:266)] MongoServerException: [Too many open connections 1,048,576; max allowed is 10: 1048577: Can't create new connection]
错误原因
这个错误是由于 MongoClient 创建的连接超过了 maxPoolSize 导致的。
解决方法
可以通过设置 maxPoolSize 的值来解决这个问题。以下是设置 maxPoolSize 的步骤：
创建一个 MongoClientOptions 对象。
设置 maxPoolSize 的值。
使用 MongoClientOptions 对象创建一个 MongoClient 对象。2023-10-18 10:18:14赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。