[ https://issues.apache.org/jira/browse/FLINK-25081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Piotr Nowojski closed FLINK-25081. ---------------------------------- Resolution: Duplicate [~reswqa], let me close this ticket so that we have all of the discussions in one place. Can you respond/repost your question in the original ticket? > When chaining an operator of a side output stream, the num records sent > displayed on the dashboard is incorrect > --------------------------------------------------------------------------------------------------------------- > > Key: FLINK-25081 > URL: https://issues.apache.org/jira/browse/FLINK-25081 > Project: Flink > Issue Type: Bug > Components: Runtime / Metrics, Runtime / Task > Affects Versions: 1.14.0 > Reporter: Lijie Wang > Priority: Major > Attachments: image-2021-11-26-20-32-08-443.png > > > As show in the following figure, "Map" is an operator of a side output > stream, the num records sent of first vertex is 0. > !image-2021-11-26-20-32-08-443.png|width=750,height=253! > > The job code is as follows: > {code:java} > final StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > SingleOutputStreamOperator<Long> dataStream = > env.addSource(new > DataGeneratorSource<>(RandomGenerator.longGenerator(1, 1000))) > .returns(Long.class) > .setParallelism(10) > .slotSharingGroup("group1"); > DataStream<Long> sideOutput = dataStream.getSideOutput(new > OutputTag<Long>("10") {}); > sideOutput.map(num -> num).setParallelism(10).slotSharingGroup("group1"); > dataStream.addSink(new > DiscardingSink<>()).setParallelism(10).slotSharingGroup("group2"); > env.execute("WordCount"); {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)