Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10740 FLIP-27: Refactor Source Interface
  3. FLINK-19205

SourceReaderContext should give access to Configuration and Hostbame

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.11.3, 1.12.0
    • API / Core
    • None

    Description

      To implement end-to-end configurability, Source Readers need access to the Flink configuration.

      Source Readers sometimes need access to the hostname of the machine running the reader task, to add locality preferences to requests for partitions from the external source system.

      The natural way to give access to both is through the SourceReaderContext.

      Attachments

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: