有谁用过 RichFilterFunction ,为啥open和close一直被调用?[阿里云实时计算 Flink版]

有谁用过 RichFilterFunction ,为啥open和close一直被调用。感觉是执行一次算子,就是会调用open和clos方法?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 是的,RichFilterFunction的open和close方法会在每次执行算子时被调用。open方法用于初始化算子,close方法用于清理算子,以及释放资源。

  2. 难道不是吗,试试RichMap 好像也是这样,可能和并行度有关——该回答整理自钉群“【③群】Apache Flink China社区”