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

avoid to call retractExpressions method of max/min function in retractable aggregate code-gen

    XMLWordPrintableJSON

Details

    Description

      after FlinkRelMdModifiedMonotonicity introduced, a max/min function whose result value is modified increasing/decreasing could ignore retraction message. We could choose regular max/min function instead of retract max/min function in code-gen. Currently, this requires the regular max/min function must implements retractExpressions method and do not throw any exceptions. A better approach is the retractable aggregate operator does not call retractExpressions method for max/min function.

      Attachments

        Issue Links

          is a child of

          Sub-task - The sub-task of the issue FLINK-11493 Finalize the Blink SQL merging efforts

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

          Web Link GitHub Pull Request #15940

          Activity

            People

              lzljs3620320 Jingsong Lee
              godfreyhe godfrey he
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: