Flink sql count 多个属性的问题

[小旋锋]

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

[Jark]

Hi，

能贴一下你的完整 SQL 吗？

On Wed, 26 Feb 2020 at 18:21, 小旋锋 <[hidden email]> 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都无法运行，请问这是什么情况呢？

[酷酷的浑蛋]

我的经验：  
count(distinct 只支持单字段)   ,  distinct  a,b 是可以的
有一个解决方式：count(distinct  concat(a,b))


| |
apache22
|
|
[hidden email]
|
签名由网易邮箱大师定制
在2020年2月26日 18:21，小旋锋<[hidden email]> 写道：
大家好:
&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都无法运行，请问这是什么情况呢？

[godfrey he]

hi, 你看到的 select count(distinct a, b) from mytable 单元测试能通过，应该是只测试 logical
plan，当前在生成 physical plan的时候，显示的禁用了多个字段

Bests,
Godfrey

apache22 <[hidden email]> 于2020年2月26日周三 下午6:56写道：

> 我的经验：
> count(distinct 只支持单字段)   ,  distinct  a,b 是可以的
> 有一个解决方式：count(distinct  concat(a,b))
>
>
> | |
> apache22
> |
> |
> [hidden email]
> |
> 签名由网易邮箱大师定制
> 在2020年2月26日 18:21，小旋锋<[hidden email]> 写道：
> 大家好:
> &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都无法运行，请问这是什么情况呢？