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.