flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Job Records In/Out metrics clarification
Date Mon, 15 Oct 2018 14:36:18 GMT
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



Mime
View raw message