[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237160#comment-17237160
]
Shengkai Fang commented on FLINK-20281:
---------------------------------------
We are also can't do window agg on upsert-kafka. Because upsert-kafka is also a
changelog stream.
> 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
> Priority: Major
>
> 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.3.4#803005)
