当前位置:首页 > 行业动态 > 正文

Flink CDC里mysql cdc 3.0.1 canel job后两个连接没释放有人遇到过吗?

确实,有用户在使用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版本的已知问题,建议升级到最新版本以解决这个问题,也可以手动关闭这两个数据库连接,以避免资源浪费。

0

随机文章