Stephan Ewen created FLINK-20063: ------------------------------------ Summary: File Source requests an additional split on every restore. Key: FLINK-20063 URL: https://issues.apache.org/jira/browse/FLINK-20063 Project: Flink Issue Type: Bug Components: Connectors / FileSystem Reporter: Stephan Ewen Assignee: Stephan Ewen Fix For: 1.12.0
Currently, the {{FileSourceReader}} requests a new split when started. That includes cases when it was restored from a checkpoint. So with every restore, the reader increases its split backlog size by one, causing problems for balanced split assignments. -- This message was sent by Atlassian Jira (v8.3.4#803005)