确实,有用户在使用Flink CDC 3.0.1版本连接MySQL时遇到了资源未释放的问题,以下是详细的分析过程和可能的解决方法。
问题描述
使用Flink CDC 3.0.1版本的MySQL connector进行数据同步,当cancel job后,发现有两个数据库连接没有被正确关闭和释放。
影响范围
该问题主要影响在Flink CDC 3.0.1版本的MySQL connector,其他版本或connector可能不受影响。
分析过程
1、确认问题:通过监控工具或者日志可以观察到,当job被取消后,仍有两个数据库连接保持活动状态。
2、定位问题:通过查看Flink CDC的源码,我们发现在取消job后,应该调用close()
方法来关闭并释放所有资源,由于某种原因,这个方法没有被正确调用。
3、寻找解决方案:我们可以尝试手动调用close()
方法,或者升级到新的Flink CDC版本,看是否可以解决这个问题。
可能的解决方案
1、手动关闭连接:虽然这不是一个长期的解决方案,但在遇到这个问题时,可以尝试手动关闭这两个数据库连接。
2、升级Flink CDC版本:如果问题仍然存在,建议升级到最新的Flink CDC版本,看是否可以解决这个问题,新版本可能已经修复了这个问题。
上文归纳
这是一个Flink CDC 3.0.1版本的已知问题,建议升级到最新版本以解决这个问题,也可以手动关闭这两个数据库连接,以避免资源浪费。
原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/560681.html
本网站发布或转载的文章及图片均来自网络,其原创性以及文中表达的观点和判断不代表本网站。如有问题,请联系客服处理。
发表回复