有谁用过 RichFilterFunction ，为啥open和close一直被调用。感觉是执行一次算子，就是会调用open和clos方法？
有谁用过 RichFilterFunction ，为啥open和close一直被调用？[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
=====这是一个广告位，招租中，联系qq 78315851====
同尘云，您身边的云智能顾问
有谁用过 RichFilterFunction ，为啥open和close一直被调用。感觉是执行一次算子，就是会调用open和clos方法？
是的，RichFilterFunction的open和close方法会在每次执行算子时被调用。open方法用于初始化算子，close方法用于清理算子，以及释放资源。
难道不是吗，试试RichMap 好像也是这样，可能和并行度有关——该回答整理自钉群“【③群】Apache Flink China社区”