[FLINK-5800] Make sure that the CheckpointStreamFactory is instantiated once per operator only

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.0
• Fix Version/s: 1.2.1, 1.3.0
• Component/s: Runtime / State Backends
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 14/Feb/17 21:16
• Updated: 15/Feb/17 18:01
• Resolved: 15/Feb/17 18:00

Description

Previously, the CheckpointSteamFactory was created once per checkpoint, and its repeated initialization logic (like ensuring existence of the parent directory) caused unnecessary load on some file systems at very large scale.

Issue Links

• links to: GitHub Pull Request #3312