tongchenkeji 发表于:2023-2-7 14:28:200次点击 已关注取消关注 关注 私信 有谁用过 RichFilterFunction ,为啥open和close一直被调用?[阿里云实时计算 Flink版] 暂停朗读为您朗读 有谁用过 RichFilterFunction ,为啥open和close一直被调用。感觉是执行一次算子,就是会调用open和clos方法? 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# 实时计算 Flink版3179
认真学习的heartAM 2023-11-27 18:16:55 1 是的,RichFilterFunction的open和close方法会在每次执行算子时被调用。open方法用于初始化算子,close方法用于清理算子,以及释放资源。
是的,RichFilterFunction的open和close方法会在每次执行算子时被调用。open方法用于初始化算子,close方法用于清理算子,以及释放资源。
难道不是吗,试试RichMap 好像也是这样,可能和并行度有关——该回答整理自钉群“【③群】Apache Flink China社区”