[FLINK-9530] Task numRecords metrics broken for chains

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.5.0, 1.6.0
• Fix Version/s: 1.5.1, 1.6.0
• Component/s: Runtime / Metrics
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 05/Jun/18 12:52
• Updated: 14/Jun/18 23:51
• Resolved: 14/Jun/18 23:50

Description

The numRecordsIn/Out metrics for tasks is currently broken. We are wrongly adding up the numRecordsIn/Out metrics for all operators in the chain, instead of just the head/tail operators.

Issue Links

• links to: GitHub Pull Request #6126