Flink CDC中请问这个window aggregation能使用mysql-cdc形式数据吗？

提到的 Window Aggregation，它是 Flink 中用于对数据流进行窗口聚合操作的功能。Window Aggregation 可以在窗口上执行聚合函数（如 SUM、COUNT、AVG 等），以生成聚合结果。这个功能与 CDC 连接器的选择和数据源无关，您可以在 Flink 中使用 Window Aggregation 来对任何支持的数据源进行窗口聚合操作。

他这个是jdbc流读，读取完就没了，job会显示finish技术状态，何来cdc。flinkSQL能实现这种当天的实时求和前提是依赖状态的ttl应该要大于1天，如果你想cdc开窗不行，只能聚合。如果一天的数据量很大，这种计算包含历史数据的，非常耗内存，你考虑下。同步基表数据到另外一个olap数据库，用olap数据库查每天的聚合结果。此回答整理至钉群“Flink CDC 社区”。