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
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
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
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