You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2023/05/31 08:11:37 UTC
[pulsar] branch master updated: [improve][broker] Do not expose bucketDelayedIndexStats (#20383)
This is an automated email from the ASF dual-hosted git repository.
technoboy 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 9f93af32d78 [improve][broker] Do not expose bucketDelayedIndexStats (#20383)
9f93af32d78 is described below
commit 9f93af32d7844003d03cf754ec8cfc50b7177220
Author: Cong Zhao <zh...@apache.org>
AuthorDate: Wed May 31 16:11:30 2023 +0800
[improve][broker] Do not expose bucketDelayedIndexStats (#20383)
---
.../apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java | 2 ++
.../org/apache/pulsar/common/policies/data/stats/TopicStatsImpl.java | 1 +
2 files changed, 3 insertions(+)
diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java
index 2bfa54da6a0..cfc6cab9e11 100644
--- a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java
+++ b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java
@@ -18,6 +18,7 @@
*/
package org.apache.pulsar.common.policies.data.stats;
+import com.fasterxml.jackson.annotation.JsonIgnore;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedHashMap;
@@ -134,6 +135,7 @@ public class SubscriptionStatsImpl implements SubscriptionStats {
/** The size of DelayedDeliveryTracer memory usage. */
public long delayedMessageIndexSizeInBytes;
+ @JsonIgnore
public Map<String, TopicMetricBean> bucketDelayedIndexStats;
/** SubscriptionProperties (key/value strings) associated with this subscribe. */
diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/TopicStatsImpl.java b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/TopicStatsImpl.java
index f0141bd58d3..7a48df89b8b 100644
--- a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/TopicStatsImpl.java
+++ b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/TopicStatsImpl.java
@@ -140,6 +140,7 @@ public class TopicStatsImpl implements TopicStats {
public long delayedMessageIndexSizeInBytes;
/** Map of bucket delayed index statistics. */
+ @JsonIgnore
public Map<String, TopicMetricBean> bucketDelayedIndexStats;
/** The compaction stats. */