[FLINK-19059] Support to consume retractions for OVER WINDOW operator

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Bonnie Varghese
• Reporter: Jark Wu
• Created: 27/Aug/20 07:12
• Updated: 13/Dec/24 14:48

Description

Currently, OVER WINDOW in streaming SQL only support to consume insert-only stream and doesn't support to consume retractions (i.e. contains UPDATE/DELETE messages). This results in OVER WINDOW can't be used to follow after unbounded group by or streaming join.

Issue Links

• is duplicated by: FLINK-26802 StreamPhysicalOverAggregate doesn't support consuming update and delete changes which is produced by node Deduplicate
• is duplicated by: FLINK-27969 StreamPhysicalOverAggregate doesn't support consuming update and delete changes
• is related to: FLINK-20487 Support to consume retractions for window aggregate operator
• links to: GitHub Pull Request #25753