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 <[email protected]>
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) {
