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 2025/03/14 07:22:23 UTC
(pulsar) branch master updated: [fix][test] Fix flaky PrometheusMetricsTest.testBrokerMetrics (#24042)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 694969f7ef3 [fix][test] Fix flaky PrometheusMetricsTest.testBrokerMetrics (#24042)
694969f7ef3 is described below
commit 694969f7ef35d2c049f7430e9151168938c2bbb9
Author: Philipp Dolif <52...@users.noreply.github.com>
AuthorDate: Fri Mar 14 08:22:16 2025 +0100
[fix][test] Fix flaky PrometheusMetricsTest.testBrokerMetrics (#24042)
---
.../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 fa073d3694b..ea2023e01c2 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
@@ -306,8 +306,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;
}
}