Hi,

I am doing performance test for my pipeline keeping FSStateBackend, I have
observed frequent Full GC's after processing 20M records.

When I did memory analysis using MAT, it showed that the many objects
maintained by Flink state are live.

Flink keeps the state in memory even after checkpointing , when does this
state gets removed / GC. (I am using window operator in which the DTO comes
as input)

Also why does Flink keep the state in memory after checkpointing ?

P.S Using RocksDB is not causing Full GC at all.

Regards,
Vinay Patil

Reply via email to