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

[FLIP-167] Propagate watermarks to Sink API

    XMLWordPrintableJSON

    Details

      Description

      Make it possible for sink functions / sink writers to propagate watermarks to external storage systems, as described in FLIP-167.

      Note that sink functions already obtain the current watermark upon receiving a record.  This issue is about obtaining the watermark as it is received from upstream (i.e. not dependent on receipt of a record).

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                eronwright Eron Wright
                Reporter:
                eronwright Eron Wright
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: