[flink] branch release-1.13 updated: [FLINK-26846][python] Fix the gauge metric

[dianfu]

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

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


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new aa8057e  [FLINK-26846][python] Fix the gauge metric
aa8057e is described below

commit aa8057ebdb62eed114c4a275dcb478598d30e1ce
Author: Dian Fu <dia...@apache.org>
AuthorDate: Thu Mar 24 20:34:09 2022 +0800

    [FLINK-26846][python] Fix the gauge metric
    
    This closes #19226.
---
 .../java/org/apache/flink/python/metric/FlinkMetricContainer.java   | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

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 96e127f..a184c39 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
@@ -33,7 +33,6 @@ import 
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMap
 import org.apache.beam.model.pipeline.v1.MetricsApi.MonitoringInfo;
 import org.apache.beam.runners.core.metrics.MetricsContainerImpl;
 import org.apache.beam.runners.core.metrics.MetricsContainerStepMap;
-import org.apache.beam.runners.core.metrics.MonitoringInfoConstants;
 import org.apache.beam.runners.core.metrics.MonitoringInfoMetricName;
 import org.apache.beam.sdk.metrics.DistributionResult;
 import org.apache.beam.sdk.metrics.GaugeResult;
@@ -106,10 +105,7 @@ public final class FlinkMetricContainer {
         MetricName metricName = metricResult.getKey().metricName();
         if (metricName instanceof MonitoringInfoMetricName) {
             String urn = ((MonitoringInfoMetricName) metricName).getUrn();
-            return urn.contains(MonitoringInfoConstants.Urns.USER_SUM_INT64)
-                    || 
urn.contains(MonitoringInfoConstants.Urns.USER_SUM_DOUBLE)
-                    || 
urn.contains(MonitoringInfoConstants.Urns.USER_DISTRIBUTION_DOUBLE)
-                    || 
urn.contains(MonitoringInfoConstants.Urns.USER_DISTRIBUTION_INT64);
+            return urn.startsWith("beam:metric:user");
         }
         return false;
     }