You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/02/26 15:50:01 UTC

[jira] [Closed] (FLINK-1846) Sinks inside of iterations

     [ https://issues.apache.org/jira/browse/FLINK-1846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Till Rohrmann closed FLINK-1846.
--------------------------------
    Resolution: Won't Do

Closed because of inactivity.

> Sinks inside of iterations
> --------------------------
>
>                 Key: FLINK-1846
>                 URL: https://issues.apache.org/jira/browse/FLINK-1846
>             Project: Flink
>          Issue Type: Improvement
>          Components: Distributed Coordination, 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
(v7.6.3#76005)