开发者社区> 问答> 正文

flink 1.13.2 使用avg函数对int字段求平均值,输出类型为int类型,而不是浮点型

hi!      我使用flink 1.13.2版本,在对 int 类型的字段通过avg函数求平均值时,其返回值类型为 int ,而不是 double,decimal等浮点类型,导致计算值的精度丢失,请问这是bug吗?*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-02 16:47:46 810 0
1 条回答
写回答
取消 提交回答
  • by-design 的行为, avg 就是 sum / count, flink 目前行为是根据入参类型来推断返回类型 (与 sum 以及 /

    保持一致), 想要保持高精度,可以考虑把入参 cast 成 double.*来自志愿者整理的FLINK邮件归档

    2021-12-02 17:01:13
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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