Re: State expiration in Flink

2020-06-01 Thread Yun Tang
: Re: State expiration in Flink Thanks, Yun! One more question: is it possible to create some kind of handler on clearing up the state? For example i want to flush state to external storage (e.g. HBase) before cleanup.Now we make this manually with onTimer method, but is there another way? On

Re: State expiration in Flink

2020-05-31 Thread Vasily Melnik
--- > *From:* Vasily Melnik > *Sent:* Saturday, May 30, 2020 23:29 > *To:* user > *Subject:* State expiration in Flink > > Hi . > I'm a bit confused with this point in State TTL documentation: > " By default, expired values are explicitly removed

Re: State expiration in Flink

2020-05-31 Thread Yun Tang
, May 30, 2020 23:29 To: user Subject: State expiration in Flink Hi . I'm a bit confused with this point in State TTL documentation: " By default, expired values are explicitly removed on read, such as ValueState#value, and periodically garbage collected in the background if suppor

State expiration in Flink

2020-05-30 Thread Vasily Melnik
Hi . I'm a bit confused with this point in State TTL documentation: " By default, expired values are explicitly removed on read, such as ValueState#value, and periodically garbage collected in the background if supported by the configured state backend. " Does it mean, that if i have only one even