Re: State leak in tumbling windows

2024-06-07 Thread Adam Domanski
Hi Yanfei, I'm using Flink SQL API, however isn't it like SQL is translated to DataStream's building blocks, so SQL window is in fact eg. SlicingWindowOperator? I see only such rocks dbs under a TM' /tmp/flink-io-* directory: bash-4.4$ du -d 1 . -b 1 94262 ./job__

Re: State leak in tumbling windows

2024-06-06 Thread Yanfei Lei
Hi Adam, Is your job a datastream job or a sql job? After I looked through the window-related code(I'm not particularly familiar with this part of the code), this problem should only exist in datastream. Adam Domanski 于2024年6月3日周一 16:54写道: > > Dear Flink users, > > I spotted the ever growing che