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)