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

RuntimeFilterProgram should aware join type when looking for the build side

    XMLWordPrintableJSON

Details

    Description

      Currently, runtime filter program will try to look for an Exchange as build side to avoid affecting MultiInput. It will try to push down the runtime filter builder if the original build side is not Exchange.

      Currenlty, the builder-push-down does not aware the join type, which may lead to incorrect results(For example, push down the builder to the right input of left-join).

      We should only support following cases:

      1. Inner join: builder can push to left + right input
      2. semi join: builder can push to left + right input
      3. left join: builder can only push to the left input
      4. right join: builder can only push to the right input

      Attachments

        Issue Links

          Activity

            People

              wanglijie Lijie Wang
              wanglijie Lijie Wang
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: