[ https://issues.apache.org/jira/browse/FLINK-5800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-5800. --------------------------------- Resolution: Fixed Fixed in - 1.2.1 via d3435b05f9ca94b4b9bd32df22b49f3829287075 - 1.3.0 via 04e6758abbadf39a12848a925e6e087e060bbe3a > Make sure that the CheckpointStreamFactory is instantiated once per operator > only > --------------------------------------------------------------------------------- > > Key: FLINK-5800 > URL: https://issues.apache.org/jira/browse/FLINK-5800 > Project: Flink > Issue Type: Improvement > Components: State Backends, Checkpointing > Affects Versions: 1.2.0 > Reporter: Stephan Ewen > Assignee: Stephan Ewen > Fix For: 1.3.0, 1.2.1 > > > 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. -- This message was sent by Atlassian JIRA (v6.3.15#6346)