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; } }