Lijie Wang created FLINK-25081:
----------------------------------
Summary: 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
Affects Versions: 1.14.0
Reporter: Lijie Wang
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)
