We also faced the same issue with Flink 1.16.1. Please enable jemalloc as a
memory allocator, it fixed the issue for us.
On Wed, Sep 6, 2023 at 9:07 PM Kenan Kılıçtepe wrote:
> Hi,
> Thanks for the answer.
> I will try the documents you have shared.
> But still it would be great if you can take
Hi Shammon,
These configs exist in Flink WebUI. We have set
exeEnv.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime); Do
you think it can create some issues for the HOP(proctime, some interval,
some interval) and not releasing the state for checkpoints?
I am really confused about why s
Hi Shammon,
state.backend: rocksdb
state.backend.incremental: true
This is already set in the Flink-conf. Anything else that should be taken
care of for the incremental checkpointing? Is there any related bug in
Flink 1.16.1? we have recently migrated to Flink 1.16.1 from Flink 1.13.6.
What can b
Hello Shammon,
Thank you for your assistance.
I have already enabled the incremental checkpointing, Attaching the
screenshot. Can you please elaborate on what makes you think it is not
enabled, It might hint towards the issue. The problem is checkpoint size is
not going down and keeps on increasin
