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

Add a dedicated phase to materialize time indicators for nodes produce updates

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • None
    • Table SQL / Planner
    • None

    Description

      As discussed here, we need a dedicated phase to materialize time indicators for nodes produce updates.

      Details:
      Currently, we materialize time indicators in `RelTimeInidicatorConverter`. We need to introduce another materialize phase that materializes all time attributes on nodes that produce updates. We can not do it inside `RelTimeInidicatorConverter`, because only later, after physical optimization phase, we know whether it is a non-window outer join which will produce updates

      There are a few other things we need to consider.

      • Whether we can unify the two converter phase.
      • Take window with early fire into consideration(not been implemented yet). In this case, we don't need to materialize time indicators even it produces updates.

      Attachments

        Activity

          People

            Unassigned Unassigned
            hequn8128 Hequn Cheng
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: