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

Support retract message for StreamExecGroupWindowAggregate in blink planner

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Table SQL / Planner
    • Labels:
      None

      Description

      Currently the `WindowOperator` in blink planner actually supports retract messages, however in StreamExecGroupWindowAggregate, we throws exception if input is retract. IMO, we can remove this check and let `StreamExecGroupWindowAggregate` support retract messages. This will enhance the ability of blink planner very much.

       

      cc Jark Wu

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              libenchao Benchao Li
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: