[ 
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)

Reply via email to