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

Extend watermark-related features for SQL

    XMLWordPrintableJSON

Details

    • Flink now enable user config watermark emit strategy/watermark alignment/watermark idle-timeout in flink sql job with dynamic table options and 'Options' hint.

    Description

      This issue aims to extend watermark-related features which are discussed in https://cwiki.apache.org/confluence/display/FLINK/FLIP-296%3A+Extend+watermark-related+features+for+SQL

      Features to extends:

      • Configurable watermark emit strategy
      • Dealing with idle sources
      • Watermark alignment

      Attachments

        Issue Links

          Activity

            People

              catyee Yuan Kui
              catyee Yuan Kui
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: