[
https://issues.apache.org/jira/browse/FLINK-20674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251772#comment-17251772
]
Piotr Nowojski commented on FLINK-20674:
----------------------------------------
I'm not sure if this is a bug. [There was some
discussion|https://issues.apache.org/jira/browse/FLINK-18808?focusedCommentId=17175509&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-17175509]
about the same issue, but with broadcasting the records. Broadcasting/union
works more or less the same in this regard. One record is produced by a task,
multiple records are sent.
I was suggesting to rename the output metric from "Records Sent" to "Records
Produced" as an easy fix.
Btw, [~NicoK] I think this is a duplicated ticket of FLINK-18808?
> 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.12.0, 1.11.3
> Reporter: Nico Kruber
> Priority: Major
>
> 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)
