Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3643 Improve Windowing
  3. FLINK-3648

Introduce Trigger Test Harness

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • None
    • API / DataStream
    • None

    Description

      As mentioned in https://docs.google.com/document/d/1Xp-YBf87vLTduYSivgqWVEMjYUmkA-hyb4muX3KRl08/edit# we should build on the processing-time clock introduced in FLINK-3646 and add a testing harness for triggers. The harness should allow inputting elements, updating watermark, updating processing-time and firing timers. The output of the trigger as well as state managed by the partitioned state abstraction should be observable to verify correct trigger behavior.

      Then, we should add tests for all triggers.

      Attachments

        Issue Links

          depends upon

          Sub-task - The sub-task of the issue FLINK-3647 Change StreamSource to use Processing-Time Clock Service

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #2199

          Activity

            People

              kkl0u Kostas Kloudas
              aljoscha Aljoscha Krettek
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: