[FLINK-11230] Sum of FlinkSql after two table union all.The value is too large.

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.7.0
• Fix Version/s: 1.7.0
• Component/s: Table SQL / API
• Labels: test
• Flags: Important
• Assignee: Unassigned
• Reporter: jiwei
• Created: 29/Dec/18 04:52
• Updated: 08/Jan/19 01:32
• Resolved: 08/Jan/19 01:32

Description

SELECT k AS KEY, SUM(p) AS pv
FROM (
SELECT tumble_start(stime, INTERVAL '1' minute) AS k
, COUNT AS p
FROM flink_test1
GROUP BY tumble(stime, INTERVAL '1' minute)
UNION ALL
SELECT tumble_start(stime, INTERVAL '1' minute) AS k
, COUNT AS p
FROM flink_test2
GROUP BY tumble(stime, INTERVAL '1' minute)
) t
GROUP BY k

The Result of executing this sql is about 7000 per minute and keeping increasing.But the result is 60 per minute for per table.Is there an error in my SQL statement?