Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10886 Event time synchronization across sources
  3. FLINK-10888

Expose new global watermark RPC to sources

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Implemented
    • None
    • None
    • Connectors / Common
    • None
    • Implemented for the Kinesis consumer.

    Description

      Expose new JobMaster RPC for watermark tracking to Source implementations so it can be used to align reads across sources.

      Attachments

        Activity

          People

            jgrier Jamie Grier
            jgrier Jamie Grier
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: