Flink добавить TTL к существующему состоянию значения

Question

Для одного из наших заданий Flink мы обнаружили состояние, вызывающее утечку состояния. Чтобы это исправить, нам нужно добавить TTL в состояние, вызывающее утечку, однако мы хотели бы сохранить существующее состояние (точку сохранения). Если мы добавим TTL к состоянию значения, сможем ли мы использовать существующую точку сохранения? Спасибо.

Answer 1

Нет, в соответствии с документами это не будет работать:

Попытка восстановить состояние, которое ранее было настроено без TTL, с использованием дескриптора с поддержкой TTL или наоборот может привести к сбою совместимости и StateMigrationException.

Однако вы можете использовать API процессора состояния для выполнения sh этого.

Однако, как именно вы должны это сделать, зависит от того, какое это состояние, как оно было сериализовано, и имеет ли оператор UID.