This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit cc842629a514a39cf6e083cc2d7e694126e35141 Author: zzb <[email protected]> AuthorDate: Thu Feb 12 19:45:25 2026 +0800 [fix][test] fix testBatchMetadataStoreMetrics. (#25241) (cherry picked from commit 9db31cca40e3948182386b6930907daf449abd41) --- .../apache/pulsar/broker/stats/MetadataStoreStatsTest.java | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/MetadataStoreStatsTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/MetadataStoreStatsTest.java index 986bfc1eb7a..d6d8b0ab2f7 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/MetadataStoreStatsTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/MetadataStoreStatsTest.java @@ -195,7 +195,6 @@ public class MetadataStoreStatsTest extends BrokerTestBase { String metricsStr = output.toString(); Multimap<String, Metric> metricsMap = parseMetrics(metricsStr); - Collection<Metric> executorQueueSize = metricsMap.get("pulsar_batch_metadata_store_executor_queue_size"); Collection<Metric> opsWaiting = metricsMap.get("pulsar_batch_metadata_store_queue_wait_time_ms" + "_sum"); Collection<Metric> batchExecuteTime = metricsMap.get("pulsar_batch_metadata_store_batch_execute_time_ms" + "_sum"); @@ -203,7 +202,6 @@ public class MetadataStoreStatsTest extends BrokerTestBase { String metricsDebugMessage = "Assertion failed with metrics:\n" + metricsStr + "\n"; - Assert.assertTrue(executorQueueSize.size() > 1, metricsDebugMessage); Assert.assertTrue(opsWaiting.size() > 1, metricsDebugMessage); Assert.assertTrue(batchExecuteTime.size() > 0, metricsDebugMessage); Assert.assertTrue(opsPerBatch.size() > 0, metricsDebugMessage); @@ -213,17 +211,6 @@ public class MetadataStoreStatsTest extends BrokerTestBase { expectedMetadataStoreName.add(MetadataStoreConfig.CONFIGURATION_METADATA_STORE); AtomicInteger matchCount = new AtomicInteger(0); - for (Metric m : executorQueueSize) { - Assert.assertEquals(m.tags.get("cluster"), "test", metricsDebugMessage); - String metadataStoreName = m.tags.get("name"); - if (isExpectedLabel(metadataStoreName, expectedMetadataStoreName, matchCount)) { - continue; - } - Assert.assertTrue(m.value >= 0, metricsDebugMessage); - } - Assert.assertEquals(matchCount.get(), expectedMetadataStoreName.size()); - - matchCount = new AtomicInteger(0); for (Metric m : opsWaiting) { Assert.assertEquals(m.tags.get("cluster"), "test", metricsDebugMessage); String metadataStoreName = m.tags.get("name");
