You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by haishui <ha...@126.com> on 2022/06/27 06:09:28 UTC

Flink状态过期时是否可以将其输出到日志中

Hi,
Flink的状态过期是否能像咖啡因缓存那样，在数据过期时调用回调函数将过期的内容打印在日志中。

Best Regards!

回复: Flink状态过期时是否可以将其输出到日志中

Posted by haishui <ha...@126.com>.

有什么方式可以获取过期的状态呢，似乎flink没有提供这方面的接口

发件人: yidan zhao
发送时间: 2022年7月8日 13:46
收件人: user-zh
主题: Re: Flink状态过期时是否可以将其输出到日志中

可以考虑通过sideout方式自己打印，或者补充计算。

haishui <ha...@126.com> 于2022年6月27日周一 14:10写道：
>
> Hi,
> Flink的状态过期是否能像咖啡因缓存那样，在数据过期时调用回调函数将过期的内容打印在日志中。
>
> Best Regards!

Re: Flink状态过期时是否可以将其输出到日志中

Posted by yidan zhao <hi...@gmail.com>.

可以考虑通过sideout方式自己打印，或者补充计算。

haishui <ha...@126.com> 于2022年6月27日周一 14:10写道：
>
> Hi,
> Flink的状态过期是否能像咖啡因缓存那样，在数据过期时调用回调函数将过期的内容打印在日志中。
>
> Best Regards!

Re: Flink状态过期时是否可以将其输出到日志中

Posted by yanfei lei <fr...@gmail.com>.

Hi, Flink暂时不支持过期清理时的回调函数。如果用得是cleanupIncrementally策略（https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/state/#cleanup-of-expired-state），可以自行在`TtlIncrementalCleanup`类中添加相应的log。

> 2022年6月27日 下午2:09，haishui <ha...@126.com> 写道：
> 
> Hi,
> Flink的状态过期是否能像咖啡因缓存那样，在数据过期时调用回调函数将过期的内容打印在日志中。
> 
> Best Regards!