[
https://issues.apache.org/jira/browse/FLINK-1846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14485198#comment-14485198
]
Markus Holzemer commented on FLINK-1846:
----------------------------------------
I used my reworking of the iteration handling as a basis.
> Sinks inside of iterations
> --------------------------
>
> Key: FLINK-1846
> URL: https://issues.apache.org/jira/browse/FLINK-1846
> Project: Flink
> Issue Type: Improvement
> Components: Distributed Runtime, Local Runtime, Optimizer
> Reporter: Markus Holzemer
> Assignee: Markus Holzemer
> Priority: Minor
>
> I startet work on adding support for file sinks inside of iterations to flink.
> My current plan includes two different modes: one where only the output file
> of the last iteration is kept and one where the output file of every single
> iteration is kept (the corresponding superstep number is added as a prefix).
> I am also thinking about adding a mode where the output of every iteration is
> appended to one file or where a "sliding window" of n files is kept for all
> iterations.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
