Hi! Checkpoint sizes are highly related to your job. Incremental checkpointing will help only when the values in the state are converging (for example a distinct count aggregation).
If possible, could you provide your user code or explain what jobs are you running? Lei Wang <leiwang...@gmail.com> 于2021年10月11日周一 下午4:16写道： > > [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 > > >
