Re: Flink sql count 多个属性的问题

Wed, 26 Feb 2020 02:45:47 -0800 

Hi，

能贴一下你的完整 SQL 吗？

On Wed, 26 Feb 2020 at 18:21, 小旋锋 <[email protected]> wrote:

> 大家好:
> &nbsp; &nbsp; &nbsp; &nbsp; 我在flink官方文档上看到内置聚合函数count的函数头是这样的
> &nbsp; &nbsp; &nbsp; &nbsp; count([all] Expression | distinct Expression1
> [, Expression2])
> &nbsp; &nbsp; &nbsp; &nbsp; 所以它应该可以对多个属性进行distinct去重，而且我在源码的单元测试里也看到有几个用例
> select count(distinct a, b) from mytable，并且是可以运行通过的
> &nbsp; &nbsp; &nbsp; &nbsp; 但是我自己写sql却运行不起来，报异常&nbsp; codegenexpression.
> No matching accumulate methods for Aggregation function.
> ......CountAggFunction with Parameters (Java.lang.String, java.lang.Long)
> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;Flink1.8和1.9都无法运行，请问这是什么情况呢？

回复