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

Enable Side Output for late events on IntervalJoins

    XMLWordPrintableJSON

Details

    Description

      Currently it appears that interval joins silently drop late events: https://github.com/apache/flink/blob/83a2541475228a4ff9e9a9def4049fb742353549/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java#L231

      It would be great if those events would instead get sent to a side output, like you can enable for other windowed join operations.

      Attachments

        Issue Links

          is fixed by

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-25323 Support side output late data for interval join

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

          Bug - A problem which impairs or prevents the functions of the product. FLINK-29387 IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed
          links to

          Web Link GitHub Pull Request #18118

          Activity

            People

              stupid_pig chenyuzhi
              astraussman Andrew Straussman
              Votes:
              1 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: