[jira] [Created] (FLINK-20674) Wrong send/received stats with UNION ALL

[Shang Yuanchun (Jira)]

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)