There is a known issue in 1.5.0 with the numRecordsIn/Out metrics for chained tasks: https://issues.apache.org/jira/browse/FLINK-9530

This has been fixed in 1.5.1.

On 15.10.2018 14:37, Rafi Aroch wrote:
Hi,

Below is the In/Out metrics as they appear in the Flink UI.
I was wondering what are the possible reasons that the "Records sent" of one operator is different than the "Records received" of the next one. I would expect to see the same number...

image.png

* We're using Flink 1.5.0 version.

Thanks,
Rafi


Reply via email to