[FLINK-5778] Split FileStateHandle into fileName and basePath

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Component/s: Runtime / State Backends
• Assignee: Unassigned
• Reporter: Ufuk Celebi
• Created: 10/Feb/17 16:15
• Updated: 08/Nov/17 14:44
• Resolved: 08/Nov/17 14:44

Description

Store the statePath as a basePath and a fileName and allow to overwrite the basePath. We cannot overwrite the base path as long as the state handle is still in flight and not persisted. Otherwise we risk a resource leak.

We need this in order to be able to relocate savepoints.

interface RelativeBaseLocationStreamStateHandle {

   void clearBaseLocation();

   void setBaseLocation(String baseLocation);

}

FileStateHandle should implement this and the SavepointSerializer should forward the calls when a savepoint is stored or loaded, clear before store and set after load.

Issue Links

• links to: GitHub Pull Request #3442