开发者社区> 问答> 正文
1
0
分享

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都无法运行,请问这是什么情况呢?*来自志愿者整理的flink邮件归档

展开
收起
船长的小螺号 2021-12-03 10:21:57 1472 0
举报
飞天免费试用计划
领取免费云资源,开启云上实践第一步
实时计算 Flink 版
5000CU*H 3个月
额度3个月内有效
1 条回答
写回答
取消 提交回答
  • hi, 你看到的 select count(distinct a, b) from mytable 单元测试能通过,应该是只测试 logical

    plan,当前在生成 physical plan的时候,显示的禁用了多个字段*来自志愿者整理的FLINK邮件归档

    2021-12-03 10:49:31 举报
    赞同 评论 打赏

    评论

    全部评论 (0)

    登录后可评论
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等