(pulsar) branch master updated: [fix][test] fix testBatchMetadataStoreMetrics. (#25241)

[xyz]

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

xyz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 9db31cca40e [fix][test] fix testBatchMetadataStoreMetrics. (#25241)
9db31cca40e is described below

commit 9db31cca40e3948182386b6930907daf449abd41
Author: zzb <48124861+zhaizh...@users.noreply.github.com>
AuthorDate: Thu Feb 12 19:45:25 2026 +0800

    [fix][test] fix testBatchMetadataStoreMetrics. (#25241)
---
 .../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");