用flink 1.11.2 查询hive表自关联(self inner join) 结果不正确
我用相同的一个表自己 inner join 自己，取不同时间点，得到相同值
sql是这样，p5m 和 p0m 都是 snmpprobe.p_snmp_ifxtable 表，时间不同 select p0m.coltime, p0m.ifhcinoctets a, p0m.ifhcoutoctets c, p5m.coltime, p5m.ifhcinoctets b, p5m.ifhcoutoctets d from snmpprobe.p_snmp_ifxtable as p0m inner join snmpprobe.p_snmp_ifxtable as p5m on p0m.id=p5m.id and p0m.mibindex=p5m.mibindex where p5m.dt='2020-11-23' and p5m.hh='01' and p5m.mi='00' and p5m.mibindex=4 and p5m.ip='172.31.28.4' and p0m.dt='2020-11-23' and p0m.hh='00' and p0m.mi='55';
用flink sql client执行，计算结果是 coltime，a，c，coltime0， b，d 2020-11-23T01:00 ，3702300836，5541513669，2020-11-23T01:00，3702300836，5541513669 这里 coltime= coltime0，都是2020-11-23T01:00， 同时 a=b，c=d
hive 行命令查询结果是 2020-11-23 00:55:00.000000000,3702187169,5541332531,2020-11-23 01:00:00.000000000,3702300836,5541513669 coltime=2020-11-23 00:55:00.000000000 ， coltime0=2020-11-23 01:00:00.000000000，a!=c, b!=d
flink 结果明显不正确，flink sql 的self join 需要什么特殊写法吗？
*来自志愿者整理的flink邮件归档
写回答
-
自己回答一下，供其他人参考。
换成flink 1.12.0-rc1，用相同sql处理相同数据，结果跟 hive 计算的结果相同，确认是 1.11.2 的一个bug，1.12应该已经改正了
*来自志愿者整理的flink邮件归档
2021-12-06 14:06:43赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
