Flink CDC该连接已关闭。
sqlserver 全量阶段数据读取几百万后报这个错,可能原因是什么 ,jdbc也关闭了,为了不锁表读的是快照?io.debezium.pipeline.ErrorHandler - Producer failure 。java.lang.RuntimeException: com.microsoft.sqlserver.jdbc.SQLServerException: read_uncommitted
根据您提供的信息,您在使用 Flink CDC(Change Data Capture)读取 SQL Server 数据库的全量阶段数据时遇到了报错 "该连接已关闭",并且报错信息中提到了 "read_uncommitted"。
这个错误可能是由以下原因导致的:
连接超时或连接被关闭:该错误可能是由于数据库连接超时或连接被关闭导致的。请确保您的数据库连接设置合理,并且没有出现连接超时的情况。还可以检查您的代码,确保在需要使用数据库连接时正确地创建和关闭连接。
数据库隔离级别设置问题:您提到了 "read_uncommitted",它是 SQL Server 的一个隔离级别。该隔离级别允许读取未提交的数据,可能会引发并发问题和数据不一致性。建议将隔离级别设置为默认的 "read_committed",以确保读取到的数据是已提交的数据,并避免并发问题。
数据库锁表:您提到了为了不锁表读取快照。在读取大量数据时,可能会导致数据库锁定表或资源,从而导致连接被关闭。建议您确保数据库的并发控制和资源管理机制能够支持您的读取需求,并避免因为锁表导致连接关闭的情况发生。
其他问题:除了上述原因外,还可能存在其他问题导致连接关闭,例如网络中断、数据库配置不正确等。您可以查看数据库的日志和相关错误信息,以获取更多关于连接关闭的详细信息。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。