Ruidong Li created FLINK-7776: --------------------------------- Summary: remove duplicate records in group aggregation Key: FLINK-7776 URL: https://issues.apache.org/jira/browse/FLINK-7776 Project: Flink Issue Type: Improvement Components: Table API & SQL Reporter: Ruidong Li Assignee: Ruidong Li
the current group aggregation will compare the last {{Row}} and current {{Row}} when {{generateRetraction}} is {{true}} and {{firstRow}} is {{false}} in {{GroupAggProcessFunction}}, this logic should be applied to all cases when {{firstRow}} is false -- This message was sent by Atlassian JIRA (v6.4.14#64029)