窗口函数两次执行结果不一致

[whitecloud6688]

请问一样的窗口函数语句，为啥两次执行的结果不一样呢？谢谢

Flink SQL> SELECT window_start

    ,window_end
    ,window_time
    ,SUM(price) price
    ,COUNT(price) AS cnt

FROM TABLE( TUMBLE(TABLE Bid, DESCRIPTOR(bidtime), INTERVAL '1' HOUR))
GROUP BY window_start
,window_end
,window_time
;
+----+-------------------------+-------------------------+-------------------------+--------------------------------+----------------------+
| op | window_start | window_end | window_time | price | cnt |
+----+-------------------------+-------------------------+-------------------------+--------------------------------+----------------------+
| +I | 2019-05-15 08:00:00.000 | 2019-05-15 09:00:00.000 | 2019-05-15 08:59:59.999 | 6.0 | 1 |
| +I | 2020-04-15 08:00:00.000 | 2020-04-15 09:00:00.000 | 2020-04-15 08:59:59.999 | 21.0 | 6 |
| +I | 2020-04-15 10:00:00.000 | 2020-04-15 11:00:00.000 | 2020-04-15 10:59:59.999 | 7.0 | 1 |
| +I | 2020-04-16 08:00:00.000 | 2020-04-16 09:00:00.000 | 2020-04-16 08:59:59.999 | 1.0 | 1 |
| +I | 2020-05-15 08:00:00.000 | 2020-05-15 09:00:00.000 | 2020-05-15 08:59:59.999 | 6.0 | 1 |
+----+-------------------------+-------------------------+-------------------------+--------------------------------+----------------------+
Received a total of 5 rows

Flink SQL> SELECT window_start

    ,window_end
    ,window_time
    ,SUM(price) price
    ,COUNT(price) AS cnt

FROM TABLE( TUMBLE(TABLE Bid, DESCRIPTOR(bidtime), INTERVAL '1' HOUR))
GROUP BY window_start
,window_end
,window_time
;
+----+-------------------------+-------------------------+-------------------------+--------------------------------+----------------------+
| op | window_start | window_end | window_time | price | cnt |
+----+-------------------------+-------------------------+-------------------------+--------------------------------+----------------------+
| +I | 2020-04-15 08:00:00.000 | 2020-04-15 09:00:00.000 | 2020-04-15 08:59:59.999 | 21.0 | 6 |
| +I | 2020-04-15 10:00:00.000 | 2020-04-15 11:00:00.000 | 2020-04-15 10:59:59.999 | 7.0 | 1 |
| +I | 2020-04-16 08:00:00.000 | 2020-04-16 09:00:00.000 | 2020-04-16 08:59:59.999 | 1.0 | 1 |
| +I | 2020-05-15 08:00:00.000 | 2020-05-15 09:00:00.000 | 2020-05-15 08:59:59.999 | 6.0 | 1 |
+----+-------------------------+-------------------------+-------------------------+--------------------------------+----------------------+
Received a total of 4 rows

Flink SQL> select * from bid;
+----+----------------------+-------------------------+--------------------------------+--------------------------------+
| op | uuid | bidtime | price | item |
+----+----------------------+-------------------------+--------------------------------+--------------------------------+
| +I | 1 | 2020-04-15 08:05:00.000 | 4.0 | C |
| +I | 2 | 2020-04-15 08:07:00.000 | 2.0 | A |
| +I | 3 | 2020-04-15 08:09:00.000 | 5.0 | D |
| +I | 4 | 2020-04-15 08:11:00.000 | 3.0 | B |
| +I | 5 | 2020-04-15 08:13:00.000 | 1.0 | E |
| +I | 6 | 2020-04-15 08:17:00.000 | 6.0 | F |
| +I | 7 | 2020-04-15 10:11:00.000 | 7.0 | B |
| +I | 8 | 2020-04-16 08:13:00.000 | 1.0 | E |
| +I | 9 | 2020-05-15 08:17:00.000 | 6.0 | F |
| +I | 10 | 2019-05-15 08:17:00.000 | 6.0 | F |
+----+----------------------+-------------------------+--------------------------------+--------------------------------+
Received a total of 10 rows

建表语句
create table if not exists bid (
uuid bigint
,bidtime timestamp(3)
, price float
, item string
, watermark for bidtime as bidtime - interval '1' second
) with (
'connector' = 'hudi'
, 'table.type' = 'COPY_ON_WRITE'
, 'path' = '/hive/warehouse/test.db/bid'
, 'read.streaming.enable' = 'false'
, 'read.streaming.check-interval' = '10'
);

insert into bid values
(1 ,to_timestamp('2020-04-15 08:05', 'yyyy-MM-dd HH:mm'), 4.00 ,'C')
,(2 ,to_timestamp('2020-04-15 08:07', 'yyyy-MM-dd HH:mm'), 2.00 ,'A')
,(3 ,to_timestamp('2020-04-15 08:09', 'yyyy-MM-dd HH:mm'), 5.00 ,'D')
,(4 ,to_timestamp('2020-04-15 08:11', 'yyyy-MM-dd HH:mm'), 3.00 ,'B')
,(5 ,to_timestamp('2020-04-15 08:13', 'yyyy-MM-dd HH:mm'), 1.00 ,'E')
,(6 ,to_timestamp('2020-04-15 08:17', 'yyyy-MM-dd HH:mm'), 6.00 ,'F')
,(7 ,to_timestamp('2020-04-15 10:11', 'yyyy-MM-dd HH:mm'), 7.00 ,'B')
,(8 ,to_timestamp('2020-04-16 08:13', 'yyyy-MM-dd HH:mm'), 1.00 ,'E')
,(9 ,to_timestamp('2020-05-15 08:17', 'yyyy-MM-dd HH:mm'), 6.00 ,'F')
,(10 ,to_timestamp('2019-05-15 08:17', 'yyyy-MM-dd HH:mm'), 6.00 ,'F');

版本：
flink-1.14.4
hudi-0.11.0
spark-3.2.1-bin-hadoop2.7
hadoop-2.10.1