jiwei created FLINK-11230: ----------------------------- Summary: Sum of FlinkSql after two table union all.The value is too large. Key: FLINK-11230 URL: https://issues.apache.org/jira/browse/FLINK-11230 Project: Flink Issue Type: Bug Components: Table API & SQL Affects Versions: 1.7.0 Reporter: jiwei
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.But the result is 60 per minute for per table.Is there an error in your SQL statement? -- This message was sent by Atlassian JIRA (v7.6.3#76005)