You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2026/02/16 10:18:22 UTC
(pulsar) 03/05: [fix][test] fix testBatchMetadataStoreMetrics. (#25241)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit abbd4786b45bb0fe70ff737d7cf979c4b1b396a8
Author: zzb <48...@users.noreply.github.com>
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");