Flink CDC中select a,b,c,d 这种情况怎么搞呢？

在Flink CDC中，如果需要对某些列进行聚合操作，可以使用GROUP BY子句。但是，如果某个列没有被包含在GROUP BY子句中，那么这个列将不会被聚合。

在你提供的例子中，你尝试使用以下SQL语句：

SELECT a, b, c, d FROM xxx GROUP BY a, b

这里，你试图对c和d列进行分组，但是没有将它们包含在GROUP BY子句中。因此，Flink CDC会提示c和d的is not being grouped。

要解决这个问题，你需要将c和d列添加到GROUP BY子句中。修改后的SQL语句如下：

SELECT a, b, c, d FROM xxx GROUP BY a, b, c, d

这样，Flink CDC就可以正确地对a、b、c和d列进行分组了。

这种应该是sql 语法本身的约定，按照a和b group by，c和d必然无法输出了。只能算出来c 和d 聚合的结果 ，此回答整理自钉群“Flink CDC 社区”