[FLINK-23018] State factories should handle extended state descriptors

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0, 1.13.2
• Component/s: Runtime / State Backends
• Labels: pull-request-available
• Assignee: Yun Tang
• Reporter: Yun Tang
• Created: 17/Jun/21 08:21
• Updated: 28/Aug/21 12:19
• Resolved: 21/Jun/21 02:56

Description

Currently, TtlStateFactory and other state factories can only handle fixed type of state descriptors. As ValueStateDescriptor is not a final class and user could still extend it, however, TtlStateFactory cannot recognize the extending class.

TtlStateFactory should use StateDescriptor#Type to check what kind of state is.

Issue Links

• links to: GitHub Pull Request #16178