You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/12/18 13:25:00 UTC
[jira] [Created] (FLINK-20674) Wrong send/received stats with UNION
ALL
Nico Kruber created FLINK-20674:
-----------------------------------
Summary: Wrong send/received stats with UNION ALL
Key: FLINK-20674
URL: https://issues.apache.org/jira/browse/FLINK-20674
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.11.3, 1.12.0
Reporter: Nico Kruber
When using {{UNION ALL}} to union the same table twice , the number of records and bytes sent is just half of what the next task receives:
Reproducible with this:
{code}
CREATE TEMPORARY TABLE test (
`number` SMALLINT
)
WITH (
'connector' = 'datagen',
'rows-per-second' = '1'
);
SELECT * FROM (
(SELECT * FROM test)
UNION ALL
(SELECT * FROM test)
)
{code}
Arguably, the use case is not too useful but other combinations may be affected, too.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)