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)
