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
Dear Flink users,
I spotted the ever growing checkpoint size in my Flink application which
uses tumble windows.
I found such a ticket: https://issues.apache.org/jira/browse/FLINK-33192,
but no comments.
Can somebody confirm the issue?
BR,
Adam.