[FLINK-16876] Make TtlTimeProvider configurable when creating keyed state backend

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Workaround
• Affects Version/s: 1.10.0
• Component/s: Runtime / State Backends
• Labels: auto-deprioritized-major auto-deprioritized-minor

Release Note

the original problem to motivate this ticket is resolved through FLINK-16949

• Assignee: Unassigned
• Reporter: Yun Tang
• Created: 31/Mar/20 04:16
• Updated: 28/Dec/21 04:56
• Resolved: 28/Dec/21 04:56

Description

Currently, we would always use TtlTimeProvider.DEFAULT to create keyed state backend. This is somehow acceptable since we only support processing time for TTL now. However, this would make UT tests which would verify TTL logic not so convenient like FLINK-16581.

I propose to let TtlTimeProvider configurable when creating keyed state backend to not block other feature development.

Issue Links

• is related to: FLINK-16949 Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider