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

Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/03/22 16:22:25 UTC

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

Aljoscha Krettek created FLINK-3651:
---------------------------------------

             Summary: 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


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)