[fix][test] Fix flaky PrometheusMetricsTest.testBrokerMetrics

apache · Mar 1, 2025 · 3aac8f4 · 3aac8f4
1 parent d0025e7
commit 3aac8f4
Showing 1 changed file with 1 addition and 2 deletions.
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;
             }
         }