Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-1094

Simplify input split assignments

    XMLWordPrintableJSON

Details

    Description

      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.

      Attachments

        Activity

          People

            sewen Stephan Ewen
            sewen Stephan Ewen
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: