[image: image.png]

The  checkpointed data size became bigger and bigger and the node cpu is
very high when the job is doing checkpointing.
 But I have enabled incremental checkpointing:
env.setStateBackend(new RocksDBStateBackend(checkpointDir,
true));

I am using flink-1.11.2 and aliyun oss as checkpoint storage.


Any insight on this?

Thanks,

Lei

Reply via email to