Hi,
可以去社区jira上建个issue吗?如果有问题在1.11的版本里也需要修复的。
祝好
Leonard
[1] https://issues.apache.org/jira/projects/FLINK/issues/
> 在 2020年11月24日,01:03,macdoor 写道:
>
> 自己回答一下,供其他人参考。
>
> 换成flink 1.12.0-rc1,用相同sql处理相同数据,结果跟 hive 计算的结果相同,确认是 1.11.2
> 的一个bug,1.12应该已经改正了
>
>
>
> --
> Sent from: http://apache-
自己回答一下,供其他人参考。
换成flink 1.12.0-rc1,用相同sql处理相同数据,结果跟 hive 计算的结果相同,确认是 1.11.2
的一个bug,1.12应该已经改正了
--
Sent from: http://apache-flink.147419.n8.nabble.com/
我用相同的一个表自己 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=p