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

Posted to issues@flink.apache.org by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/03/29 19:16:25 UTC

[jira] [Closed] (FLINK-3651) Fix faulty RollingSink Restore

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

Ufuk Celebi closed FLINK-3651.
------------------------------
       Resolution: Fixed
    Fix Version/s: 1.0.1
                   1.1.0

Fixed in 580a177 (master), 2089029 (release-1.0)

> Fix faulty RollingSink Restore
> ------------------------------
>
>                 Key: FLINK-3651
>                 URL: https://issues.apache.org/jira/browse/FLINK-3651
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>             Fix For: 1.1.0, 1.0.1
>
>
> The RollingSink restore logic has a bug where the sink for subtask index 1 also removes files for subtask index 11 because the regex that checks for the file name also matches that one. Adding the suffix to the regex should solve the problem because then the regex for 1 will only match files for subtask index 1.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)