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

lhotari pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit c4af9e635063ba62de0be927305c56f3ac22c189
Author: Philipp Dolif <52791955+pdo...@users.noreply.github.com>
AuthorDate: Fri Mar 14 08:22:16 2025 +0100

    [fix][test] Fix flaky PrometheusMetricsTest.testBrokerMetrics (#24042)
    
    (cherry picked from commit 694969f7ef35d2c049f7430e9151168938c2bbb9)
---
 .../java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java     | 3 +--
 1 file changed, 1 insertion(+), 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
index 81c0acba440..4d0849a3406 100644
--- 
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
@@ -302,8 +302,7 @@ public class PrometheusMetricsTest extends BrokerTestBase {
 
         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;
             }
         }

Reply via email to