[fix][test] Fix flaky PrometheusMetricsTest.testBrokerMetrics (#24042)

pdolif · web-flow · commit 694969f7ef35 · 2025-03-14T00:22:16.000-07:00
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java
@@ -306,8 +306,7 @@ public void testBrokerMetrics() throws Exception {
 
         double systemCursorOutBytes = 0.0;
         for (Metric metric : topicLevelBytesOutTotal) {
-            if (metric.tags.get("subscription").startsWith(SystemTopicNames.SYSTEM_READER_PREFIX)
-                    || metric.tags.get("subscription").equals(Compactor.COMPACTION_SUBSCRIPTION)) {
+            if (metric.tags.get("subscription").startsWith(SystemTopicNames.SYSTEM_READER_PREFIX)) {
                 systemCursorOutBytes = metric.value;
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -306,8 +306,7 @@ public void testBrokerMetrics() throws Exception {`
`306`	`306`
`307`	`307`	`double systemCursorOutBytes = 0.0;`
`308`	`308`	`for (Metric metric : topicLevelBytesOutTotal) {`
`309`		`- if (metric.tags.get("subscription").startsWith(SystemTopicNames.SYSTEM_READER_PREFIX)`
`310`		`- \|\| metric.tags.get("subscription").equals(Compactor.COMPACTION_SUBSCRIPTION)) {`
	`309`	`+ if (metric.tags.get("subscription").startsWith(SystemTopicNames.SYSTEM_READER_PREFIX)) {`
`311`	`310`	`systemCursorOutBytes = metric.value;`
`312`	`311`	`}`
`313`	`312`	`}`