[jira] [Created] (FLINK-10150) Inconsistent number of "Records received" / "Records sent"

[Shang Yuanchun (Jira)]

Helmut Zechmann created FLINK-10150:
---------------------------------------

             Summary: Inconsistent number of "Records received" / "Records sent"
                 Key: FLINK-10150
                 URL: https://issues.apache.org/jira/browse/FLINK-10150
             Project: Flink
          Issue Type: Bug
          Components: Webfrontend
    Affects Versions: 1.6.0, 1.5.2, 1.4.0
            Reporter: Helmut Zechmann
         Attachments: record_counts_flink_1_3.png, record_counts_flink_1_4.png

The flink web ui displays an inconsistent number of "Records received" / "Records sent” in the job overview "Subtasks" view.

When I run the example wordcount batch job with a small input file on flink 1.3.2 I get
 * 3 records sent by the first subtask and
 * 3 records received by the second subtask

This is the result I would expect.
 

If I run the same job on flink 1.4.0 / 1.5.2 / 1.6.0 I get
 * 13 records sent by the first subtask and
 * 3 records received by the second subtask

In real life jobs the numbers are much more strange.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)