[fix][test]Flaky-test: SchemaServiceTest.testSchemaRegistryMetrics (a…

…pache#23566)
ascentstream · Nov 6, 2024 · 13133c1 · 13133c1
1 parent 8eeb0e2
commit 13133c1
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/SchemaServiceTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/SchemaServiceTest.java
@@ -180,22 +180,22 @@ public void testSchemaRegistryMetrics() throws Exception {
         Assert.assertEquals(putMetrics.size(), 0);
 
         Collection<Metric> deleteLatency = metrics.get("pulsar_schema_del_ops_latency_count");
-        for (Metric metric : deleteLatency) {
+        assertThat(deleteLatency).anySatisfy(metric -> {
             Assert.assertEquals(metric.tags.get("namespace"), namespace);
             Assert.assertTrue(metric.value > 0);
-        }
+        });
 
         Collection<Metric> getLatency = metrics.get("pulsar_schema_get_ops_latency_count");
-        for (Metric metric : getLatency) {
+        assertThat(getLatency).anySatisfy(metric -> {
             Assert.assertEquals(metric.tags.get("namespace"), namespace);
             Assert.assertTrue(metric.value > 0);
-        }
+        });
 
         Collection<Metric> putLatency = metrics.get("pulsar_schema_put_ops_latency_count");
-        for (Metric metric : putLatency) {
+        assertThat(putLatency).anySatisfy(metric -> {
             Assert.assertEquals(metric.tags.get("namespace"), namespace);
             Assert.assertTrue(metric.value > 0);
-        }
+        });
     }
 
     @Test