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

Time indicators are not always materialised for LogicalCorrelate

    XMLWordPrintableJSON

Details

    Description

      Currenty org.apache.flink.table.calcite.RelTimeIndicatorConverter#visit(LogicalCorrelate) supports only the cases if right side is LogicalTableFunctionScan. That is not always the case. For example in case of org.apache.flink.table.api.stream.table.CorrelateTest#testFilter the LogicalFilter node is being pushed down to the right side of LogicalCorrelate.

       

      CC twalthr

      Attachments

        Issue Links

          is related to

          Bug - A problem which impairs or prevents the functions of the product. FLINK-8897 Rowtime materialization causes "mismatched type" AssertionError

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

          Bug - A problem which impairs or prevents the functions of the product. FLINK-10211 Time indicators are not correctly materialized for LogicalJoin

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Activity

            People

              Unassigned Unassigned
              pnowojski Piotr Nowojski
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: