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进行批计算时,如何在数据结束时将状态写入输出的数据流中?
> 谢谢
>

回复