[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805852#comment-17805852
]
Jane Chan commented on FLINK-20281:
-----------------------------------
Fixed in master df2ecdc77b23e0e40fe151ed8a7350a6db333f91
> 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)
