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

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

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

          Activity

            People

            • Assignee:
              lzljs3620320 Jingsong Lee
              Reporter:
              godfreyhe godfrey he

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment