| 键控状态 | ValueState/ListState/MapState |
|---|---|
| 算子状态 | 算子级共享 |
| 后端 | 内存或 RocksDB |
| TTL | 状态过期清理 |
状态与 TTL
状态与 TTL
ValueStateDescriptor<Long> desc =
new ValueStateDescriptor<>("pay_sum", Types.LONG);
StateTtlConfig ttl = StateTtlConfig
.newBuilder(Time.days(7))
.setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
.build();
desc.enableTimeToLive(ttl);无 TTL 的大状态会持续膨胀，导致 Checkpoint 时间越来越长直至超时。