[FLINK-18143] Fix Python meter metric not correct problem

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Hequn Cheng
• Reporter: Hequn Cheng
• Created: 05/Jun/20 05:11
• Updated: 05/Jun/20 05:39
• Resolved: 05/Jun/20 05:39

Description

We should report the diff value instead of the total ones. Code `meter.markEvent(update);` in `FlinkMetricContainer` should be changed to `meter.markEvent(update - meter.getCount());`

Issue Links

• is part of: FLINK-18100 Test different user-defined metrics for Python UDF
• links to: GitHub Pull Request #12498