Re:如何在Flink Connector Source退出时清理资源

Mon, 23 Oct 2023 21:20:33 -0700 

Hi, 
看一下你的DynamicTableSource实现的类，如果你用的是InputFormat的旧source（用的是类似InputFormatProvider.of），可以使用InputFormat里的close方法；
如果用的是flip-27的source（用的是类似SourceProvider.of），SplitReader里也有一个close方法










--

    Best！
    Xuyang





在 2023-10-24 11:54:36，"jinzhuguang" <jinzhuguan...@163.com> 写道：
>版本：Flink 1.16.0
>
>需求：在某个source结束退出时清理相关的资源。
>
>问题：目前没有找到Source退出时相关的hook函数，不知道在哪里编写清理资源的代码。
>
>恳请大佬们指教。

回复