flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Luis Lázaro <lalaz...@keedio.com>
Subject Re: Flink UI records received/sent chained-unchained operators
Date Thu, 01 Jun 2017 14:14:17 GMT
Hi, 
i am reporting metrics from JMX and getting similar results: 

"Records received" < Records sent" if Operator  Map-> filter(condition1)->filter(condition2),
as the snapshot. 
 if Operator is Map->filter(condition1&&condition2) results are correct (Received
sent = 803)
Next operator Sink is receiving Previous_sent - Previous_Received (5332 - 4529 = 803)




Thanks in advance, any suggestion is well appreciated.

Best regards, Luis





Mime
View raw message