[jira] [Created] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

[Shang Yuanchun (Jira)]

Andrei Shumanski created FLINK-9453:
---------------------------------------

             Summary: Flink 1.5 incorrectly shows statistics in web UI
                 Key: FLINK-9453
                 URL: https://issues.apache.org/jira/browse/FLINK-9453
             Project: Flink
          Issue Type: Bug
          Components: Streaming, Web Client, Webfrontend
    Affects Versions: 1.5.0
            Reporter: Andrei Shumanski
         Attachments: Flink_1.4.PNG, Flink_1.5.PNG

Flink 1.5.0 incorrectly shows execution statistics and differently from Flink 1.4.1.

I attach screenshots from both versions. It looks like 1.5.0 sums all steps in operators connected with "forward()". It makes it impossible to understand how much data was actually consumed.

My test code:

 

 

{{public static void main(String[] args) throws Exception {}}
{{ StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();}}

{{ List<Integer> input = new ArrayList<>();}}

{{ input.add(1);}}
{{ input.add(2);}}
{{ input.add(3);}}
{{ input.add(4);}}
{{ input.add(5);}}

{{ DataStream<Integer> stream = env.fromCollection(input).rebalance();}}

{{ stream.map(i -> i+1).name("incr").forward().map(i -> i-1).name("decr").forward().print();}}

{{ env.execute();}}{{}}}



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