Re: join state TTL

2020-04-28 Thread LakeShen
Thank you for the clarification. Jark Jark Wu 于2020年4月29日周三 上午10:39写道: > If 'uu' in stream A is not updated for more than 24 hours, then it will be > cleared. (blink planner) > The state expiration strategy is "not updated for more than x time". > > Best, > Jark > > On Wed, 29 Apr 2020 at 10:19

Re: join state TTL

2020-04-28 Thread Jark Wu
If 'uu' in stream A is not updated for more than 24 hours, then it will be cleared. (blink planner) The state expiration strategy is "not updated for more than x time". Best, Jark On Wed, 29 Apr 2020 at 10:19, LakeShen wrote: > Hi Jark, > > I am a little confused about how double stream joini

Re: join state TTL

2020-04-28 Thread Jark Wu
Hi Lec, StateTtlConfig in DataStream API is a configuration on specific state, not a job level configuration. TableConfig#setIdleStateRetentionTime in TableAPI&SQL is a job level configuration which will enable state ttl for all non-time-based operator states. In blink planner, the underlying of T

join state TTL

2020-04-27 Thread lec ssmi
Hi: When the stream is joined with another stream , the cached stream data will be saved as a state and deleted as the watermark advances. I found that there is also a parameter that can set the state expiration time, such as StateTtlConfig in DataStream API, TableConfig in TableAPI &SQL .This