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