Flink，对mysql cdc作为数据源的动态表进行over分组聚合操作的时候，是什么原因？

你遇到的错误 StreamPhysicalOverAggregate doesn't support consuming update and delete changes which is produce by node tablesourcesscan TableA 表示 Flink 的 Over 窗口聚合操作不支持从 CDC（Change Data Capture）数据源接收到的更新和删除事件。

尽管你的表只有插入操作，但可能是由于 Flink 认为 CDC 数据源可能会产生更新或删除事件。因此，在执行 over 分组聚合时，它会检查数据源是否可能产生这些事件，并在发现可能存在时抛出这个错误。

要解决这个问题，你可以尝试以下方法：

1. 确保你的 Flink 版本是最新的：因为不同版本的 Flink 可能有不同的功能和限制。

2. 检查配置：确认你的 Flink 配置正确地指定了仅处理 insert 操作。这通常可以通过设置相应的属性来完成，如：

   # Flink SQL Client 或 Table API 配置
   table.sql-dialect: mysql
   
   # Debezium MySQL Connector 配置
   connector = debezium-connector-mysql
   name = binlog-source
   database.hostname = <数据库主机名>
   database.port = <数据库端口号>
   database.user = <数据库用户名>
   database.password = <数据库密码>
   database.server.id = 85744
   database.server.name = dbserver1
   database.whitelist = <你的表名>
   database.history = io.debezium.relational.history.FileDatabaseHistory
   database.history.file.filename = /path/to/dbhistory.dat
   snapshot.mode = when_needed
   

   其中 snapshot.mode = when_needed 和 database.whitelist = <你的表名> 可以帮助只处理指定表的 insert 操作。

3. 使用其他窗口操作：如果你不需要 over 窗口聚合操作中的某些特性，可以考虑使用 tumbling、sliding 或 session 窗口，它们可能对 CDC 数据源的支持更好。