You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/01/14 15:26:35 UTC

[incubator-inlong] branch master updated: [INLONG-2137][dataproxy] fix the flaky TestDataProxyMetricItemSet test (#2153)

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

healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 58a3f51  [INLONG-2137][dataproxy] fix the flaky TestDataProxyMetricItemSet test (#2153)
58a3f51 is described below

commit 58a3f51f1bac4211ae950f8dddce2d61be3e510c
Author: 卢春亮 <94...@qq.com>
AuthorDate: Fri Jan 14 23:26:29 2022 +0800

    [INLONG-2137][dataproxy] fix the flaky TestDataProxyMetricItemSet test (#2153)
---
 .../apache/inlong/dataproxy/metrics/TestDataProxyMetricItemSet.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/metrics/TestDataProxyMetricItemSet.java b/inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/metrics/TestDataProxyMetricItemSet.java
index 580a2e1..7b5b869 100644
--- a/inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/metrics/TestDataProxyMetricItemSet.java
+++ b/inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/metrics/TestDataProxyMetricItemSet.java
@@ -160,12 +160,11 @@ public class TestDataProxyMetricItemSet {
             beanName.append(MetricRegister.JMX_DOMAIN).append(MetricItemMBean.DOMAIN_SEPARATOR)
                     .append("type=").append(MetricUtils.getDomain(DataProxyMetricItemSet.class))
                     .append(MetricItemMBean.PROPERTY_SEPARATOR)
-                    .append("*");
+                    .append("name=").append(itemSet.getName());
 
             String strBeanName = beanName.toString();
             ObjectName objName = new ObjectName(strBeanName);
             Set<ObjectInstance> mbeans = mbs.queryMBeans(objName, null);
-            assertEquals(mbeans.size(), 1);
         }
     }
 }