Hi, 是想在RichFlatMapFunction结束计算前输出一些信息吗?AbstractRichFunction里有close方法,可以实现这个方法执行一些自定义的操作,这样在function close之前会执行
Best, Shammon FY On Fri, Aug 11, 2023 at 10:59 AM Liu Join <lzy139...@outlook.com> wrote: > 请问,flink1.17在使用RichFlatMapFunction进行批计算时,如何在数据结束时将状态写入输出的数据流中? > 谢谢 >