flink 1.13 不是将存量的state都处理完，才向磁盘写入吗？

在 Flink 1.13 中，通过 RocksDBStateBackend 实现的状态后端的默认行为是将所有的状态存储在内存中，直到达到某个内存使用阈值，然后再将部分状态写入磁盘。这个阈值可以通过 state.backend.rocksdb.memory.managed.fraction 和 state.backend.rocksdb.memory.managed.ratio 参数进行配置。

具体来说，在 Flink 1.13 中使用 RocksDBStateBackend 状态后端时，Flink 会按照以下的流程处理状态：

当状态被更新时，Flink 会将更新操作写入内存中的状态数据结构（如 RocksDB）。

当内存使用达到一定阈值时，Flink 会将部分状态数据写入磁盘，然后继续将新的状态数据写入内存中的状态数据结构。

当作业结束时，Flink 会将所有的状态数据写入磁盘。

需要注意的是，在默认配置下，Flink 1.13 在状态数据写入磁盘之前，会将存量的状态数据全部处理完毕。这是因为 RocksDBStateBackend 默认使用的是基于增量 Checkpoint 的方式，即只将增量的状态数据写入磁盘，而不是将全量的状态数据写入磁盘。因此，为了保证 checkpoint 的一致性，Flink 1.13 需要在将状态数据写入磁盘之前，先将存量的状态数据全部处理完毕。

如果您希望在 Flink 1.13 中实现更快的 checkpoint，可以考虑使用 state.backend.rocksdb.memory.managed.fraction 或 state.backend.rocksdb.memory.managed.ratio 参数来调整内存使用阈值，以提高内存写入磁盘的频率。需要注意的是，过度降低内存使用阈值可能会导致更频繁的磁盘写入操作，

你用datax同步一份历史数据，增量走cdc。此回答整理至钉群“Flink CDC 社区”。