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)
