Fabian Hueske created FLINK-6970: ------------------------------------ Summary: Add support for late data updates to group window aggregates Key: FLINK-6970 URL: https://issues.apache.org/jira/browse/FLINK-6970 Project: Flink Issue Type: New Feature Components: Table API & SQL Reporter: Fabian Hueske
Late arriving data is a common issue for group window aggregates. At the moment, the Table API simply drops late arriving records. Another approach are deferred computation (FLINK-6969) and late data updates. This issue proposes to add late data updates for group window aggregates. Instead of discarding the state of a window when the result has been computed, the state is kept for a certain time interval. If a late record for a window is received within this interval, an updated result is emitted (and the previous result is retracted). This feature will require a new parameter to the {{QueryConfig}} to configure the size of the late data interval. -- This message was sent by Atlassian JIRA (v6.4.14#64029)