[FLINK-28473] JobManager restart/failover doesn't trigger local recovery on TaskManagers

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.15.0, 1.15.1
• Component/s: Runtime / State Backends, Runtime / Task
• Assignee: Unassigned
• Reporter: Levani Kokhreidze
• Created: 09/Jul/22 10:51
• Updated: 25/Jul/22 10:55

Description

Hi! While experimenting with local recovery feature (Flink 1.15.1) I noticed that if JobManager is restarted TaskManagers always recover from Remote (IncrementalRemoteKeyedStateHandle). While if I restart task managers, local recovery is triggered.
 
Setup: * HA setup with Zookeeper and S3 remote storage.

• JobManager runs as StatefulSet with PersistentVolume. Both process.jobmanager.working-dir and jobmanager.resource-id are correctly configured.
• TaskManagers run as StatefulSets with PersistentVolume. Both process.taskmanager.working-dir and taskmanager.resource-id are correctly configured.