用flink 1.11.2 查询hive表自关联(self inner join) 结果不正确

[macdoor]

我用相同的一个表自己 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 需要什么特殊写法吗？




--
Sent from: http://apache-flink.147419.n8.nabble.com/

[macdoor]

自己回答一下，供其他人参考。

换成flink 1.12.0-rc1，用相同sql处理相同数据，结果跟 hive 计算的结果相同，确认是 1.11.2
的一个bug，1.12应该已经改正了



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[Leonard Xu]

Hi,

可以去社区jira上建个issue吗？如果有问题在1.11的版本里也需要修复的。

祝好
Leonard
[1] https://issues.apache.org/jira/projects/FLINK/issues/

> 在 2020年11月24日，01:03，macdoor <[hidden email]> 写道：
>
> 自己回答一下，供其他人参考。
>
> 换成flink 1.12.0-rc1，用相同sql处理相同数据，结果跟 hive 计算的结果相同，确认是 1.11.2
> 的一个bug，1.12应该已经改正了
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/