[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20281:
-----------------------------------
Labels: auto-deprioritized-major auto-deprioritized-minor
pull-request-available (was: auto-deprioritized-major auto-deprioritized-minor)
> Window aggregation supports changelog stream input
> --------------------------------------------------
>
> Key: FLINK-20281
> URL: https://issues.apache.org/jira/browse/FLINK-20281
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / Planner, Table SQL / Runtime
> Reporter: Jark Wu
> Assignee: xuyang
> Priority: Major
> Labels: auto-deprioritized-major, auto-deprioritized-minor,
> pull-request-available
> Attachments: screenshot-1.png
>
>
> Currently, window aggregation doesn't support to consume a changelog stream.
> This makes it impossible to do a window aggregation on changelog sources
> (e.g. Kafka with Debezium format, or upsert-kafka, or mysql-cdc).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
