It turns out to be a bug of StateTTL [1]. But I’m still interested in debugging window states.
Any suggestions are appreciated. Thanks! 1. https://issues.apache.org/jira/browse/FLINK-16581 <https://issues.apache.org/jira/browse/FLINK-16581> Best, Paul Lam > 2020年7月15日 13:13，Paul Lam <paullin3...@gmail.com> 写道： > > Hi, > > Since currently State Processor doesn’t support window states, what’s the > recommended way to debug window states? > > The background is that I have a SQL job whose states, mainly window > aggregation operator states, keep increasing steadily. > > The things I’ve checked: > - Outputs are as expected. > - Keys amount are capped. > - Watermarks are good, no lags. > - No back pressure. > > If I can directly read the states to find out what’s accountable for the > state size growth, that would be very intuitional and time-saving. > > Best, > Paul Lam >
