Flink CDC里数据源为数据库CDC表时，无法用表值函数啊，这种问题怎么解决？

当Flink CDC的数据源为数据库CDC表时，无法直接使用表值函数。这是因为数据库CDC表通常不支持表值函数的调用。

要解决这个问题，可以考虑以下两种方法：

1. 使用SQL查询语句：可以在Flink SQL中使用SELECT语句来查询数据库CDC表中的数据，并使用其他SQL功能（如JOIN、GROUP BY等）对数据进行处理和转换。这样可以避免直接使用表值函数的限制。

2. 自定义转换逻辑：如果需要使用特定的表值函数进行数据处理，可以自定义一个转换函数来实现该功能。在Flink CDC中，可以通过编写用户自定义的Assigner或ProcessFunction来实现数据的转换逻辑。这样可以灵活地处理数据库CDC表中的数据，并应用所需的表值函数。

直接用时间来group by ，cdc的sql不支持窗口的。此回答来自钉群Flink CDC 社区。