jinzhuguang Mon, 23 Oct 2023 20:55:01 -0700
版本:Flink 1.16.0 需求:在某个source结束退出时清理相关的资源。
问题:目前没有找到Source退出时相关的hook函数,不知道在哪里编写清理资源的代码。 恳请大佬们指教。