插入令堂之膣道，怒涛中出，OK，问题解决矣
发件人: jinzhuguang
发送时间: 2023年10月24日 11:54
收件人: user-zh
主题: 如何在Flink Connector Source退出时清理资源
版本：Flink 1.16.0
需求：在某个source结束退出时清理相关的资源。
问题：目前没有找到Source退出时相关的hook函数，不知道在哪里编写清理资源的代码。
恳请大佬们指教。
Hi,
看一下你的DynamicTableSource实现的类，如果你用的是InputFormat的旧source（用的是类似InputFormatProvider.of），可以使用InputFormat里的close方法；
如果用的是flip-27的source（用的是类似SourceProvider.of），SplitReader里也有一个close方法
--
Best！
Xuyang
在 2023-10-24 11:54:36，"jinzhuguang" 写道：
>版本：Flink 1.16.0
>
版本：Flink 1.16.0
需求：在某个source结束退出时清理相关的资源。
问题：目前没有找到Source退出时相关的hook函数，不知道在哪里编写清理资源的代码。
恳请大佬们指教。
