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

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.12.0, 1.11.3
    • Component/s: API / Core
    • Labels:
      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

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

              Dates

              • Created:
                Updated:
                Resolved: