Re: Flink状态过期时是否可以将其输出到日志中
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 写道: > > Hi, > Flink的状态过期是否能像咖啡因缓存那样,在数据过期时调用回调函数将过期的内容打印在日志中。 > > Best Regards!
回复: Flink状态过期时是否可以将其输出到日志中
有什么方式可以获取过期的状态呢,似乎flink没有提供这方面的接口 发件人: yidan zhao 发送时间: 2022年7月8日 13:46 收件人: user-zh 主题: Re: Flink状态过期时是否可以将其输出到日志中 可以考虑通过sideout方式自己打印,或者补充计算。 haishui 于2022年6月27日周一 14:10写道: > > Hi, > Flink的状态过期是否能像咖啡因缓存那样,在数据过期时调用回调函数将过期的内容打印在日志中。 > > Best Regards!
Re: Flink状态过期时是否可以将其输出到日志中
可以考虑通过sideout方式自己打印,或者补充计算。 haishui 于2022年6月27日周一 14:10写道: > > Hi, > Flink的状态过期是否能像咖啡因缓存那样,在数据过期时调用回调函数将过期的内容打印在日志中。 > > Best Regards!
Flink状态过期时是否可以将其输出到日志中
Hi, Flink的状态过期是否能像咖啡因缓存那样,在数据过期时调用回调函数将过期的内容打印在日志中。 Best Regards!