[flink] branch release-1.11 updated: [FLINK-18143][python] Fix Python meter metric incorrect value problem (#12498)

[hequn]

This is an automated email from the ASF dual-hosted git repository.

hequn pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.11 by this push:
     new 37f436e  [FLINK-18143][python] Fix Python meter metric incorrect value 
problem (#12498)
37f436e is described below

commit 37f436ec96ffa27fec6650a3ef4726a2a93cada4
Author: Hequn Cheng <hequn....@alibaba-inc.com>
AuthorDate: Fri Jun 5 13:36:08 2020 +0800

    [FLINK-18143][python] Fix Python meter metric incorrect value problem 
(#12498)
---
 .../main/java/org/apache/flink/python/metric/FlinkMetricContainer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java
 
b/flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java
index b5b3da5..dc61cc5 100644
--- 
a/flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java
+++ 
b/flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java
@@ -135,7 +135,7 @@ public final class FlinkMetricContainer {
                                }
 
                                Long update = metricResult.getAttempted();
-                               meter.markEvent(update);
+                               meter.markEvent(update - meter.getCount());
                        } else {
                                Counter counter = 
flinkCounterCache.get(flinkMetricIdentifier);
                                if (null == counter) {