Stephan Ewen created FLINK-1094:
-----------------------------------
Summary: Simplify input split assignments
Key: FLINK-1094
URL: https://issues.apache.org/jira/browse/FLINK-1094
Project: Flink
Issue Type: Improvement
Components: JobManager
Reporter: Stephan Ewen
Assignee: Stephan Ewen
Priority: Minor
The input split assigner is currently one shared instances across jobs and
inputs. The mapping between splits, split type, and assigner is very
inflexible, as it requires changing an internal class in the runtime project.
The following changes will make it simpler and more efficient:
- Attach the split assigner to the job vertex (the ExecutionJobVertex) for the
task that consumes the input splits.
- Move the input split assigner interfaces into the core project, as well as
the simple base implementations of the assigners (default and locality aware)
- Let input split producers (such as input formats) create their own assigners.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
