Hi all, I’d like to start a discussion on FLIP-XXX: Expose per downstream target numRecordsOut metric [1].
I’ve also opened a draft PR with a reference implementation to make the proposal concrete and easier to review [2]. Feedback and suggestions are very welcome. Best regards, Dennis [1] https://docs.google.com/document/d/1TlyTc6fvYGG1xlO-IFlGBC97CxilUBFdZBpLOBPdKD8/edit?usp=sharing [2] https://github.com/apache/flink/pull/28014
