[BEAM-6165] Send metrics to Flink in portable Flink runner

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.8.0
• Fix Version/s: 2.10.0
• Component/s: runner-flink
• Labels: metrics portability portability-flink
• Assignee: Ryan Williams
• Reporter: Ryan Williams
• Created: 03/Dec/18 00:11
• Updated: 17/Jan/22 14:38
• Resolved: 20/Dec/18 21:43

Description

Metrics are sent from the fn harness to runner in the Python SDK (and likely Java soon), but the portable Flink runner doesn't pass them on to Flink, which it should, so that users can see them in e.g. the Flink UI or via any Flink metrics reporters.

Issue Links

• links to: GitHub Pull Request #7183
• links to: GitHub Pull Request #7637
• links to: GitHub Pull Request #7971