[FLINK-19102] Make StateBinder a per-FunctionType entity

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: statefun-2.2.0
• Component/s: Stateful Functions
• Labels: pull-request-available
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 31/Aug/20 09:02
• Updated: 27/Apr/21 18:05
• Resolved: 01/Sep/20 10:05

Description

Currently, a single StateBinder instance is used across multiple FunctionType s for binding state objects to Flink state.

While this is fine, it creates a leak of internal runtime information to the PersistedStateRegistry class. To fix this, we need to make FunctionType a property of each individual state binder, etc. each state binder binds state for a single FunctionType.

Issue Links

• links to: GitHub Pull Request #137