[
https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiwei updated FLINK-11230:
--------------------------
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?
was:
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 my SQL statement?
> 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
> Priority: Major
> Labels: test
>
> 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?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
