Re: Question about State TTL and Interval Join

2021-06-06 Thread Yun Tang
Hi Chris, Interval Join should clean state which is not joined during interval and you don't need to set state TTL. (Actually, the states used in interval join are not exposed out and you cannot set TTL for those state as TTL is only public for user self-described states.) The checkpoint size

Re: Question about State TTL and Interval Join

2021-06-04 Thread JING ZHANG
Hi Chris, There is no need to state TTL if stateful operators only contain IntervalJoin. Please check the watermark of two input streams, does the watermark not advance for a long time? Best regards, JING ZHANG McBride, Chris 于2021年6月5日周六 上午3:17写道: > We currently have a flink 1.8 application de