We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent be57e9a commit 2dcaf0eCopy full SHA for 2dcaf0e
1 file changed
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java
@@ -233,7 +233,7 @@ public synchronized void updateStats(
233
updatedAt = System.currentTimeMillis();
234
}
235
236
- public NamespaceBundleStats invalidBundleStats(String bundleName) {
+ public synchronized NamespaceBundleStats invalidBundleStats(String bundleName) {
237
return bundleStats.remove(bundleName);
238
239
@@ -254,7 +254,7 @@ public BrokerOperabilityMetrics getBrokerOperabilityMetrics() {
254
return brokerOperabilityMetrics;
255
256
257
- public Map<String, NamespaceBundleStats> getBundleStats() {
+ public synchronized Map<String, NamespaceBundleStats> getBundleStats() {
258
return bundleStats;
259
260
0 commit comments