访问db获取初始state,是要hack下的,要自己保存一个KeySelector,算下当前记录的Key是什么,这个逻辑不用改flink,写到你业务代码里就好了。

On Wed, 24 Apr 2019 at 21:23, Shi Quan <[email protected]> wrote:

> 主要是考虑是在从异常恢复场景下,业务state是否需要重新加载。如果不需要重新加载,就不要记录这么多时间用来判断了。
>
>
>
> Sent from Mail<https://go.microsoft.com/fwlink/?LinkId=550986> for
> Windows 10
>
>
>
> ________________________________
> From: zhang yue <[email protected]>
> Sent: Wednesday, April 24, 2019 8:29:07 PM
> To: [email protected]
> Subject: Re: Flink 状态使用问题咨询
>
> 嗯,明白你的意思,initTime < openTime是做何考虑,什么情况下initTime < openTime会满足
>
> > 在 2019年4月24日,下午8:16,Shi Quan <[email protected]> 写道:
> >
> > initTime < openTime
>
>

回复