Addressed comments

apache · Feb 15, 2024 · 43db81d · 43db81d
1 parent 5776a74
commit 43db81d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/...er/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/data/BrokerLoadData.java b/...er/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/data/BrokerLoadData.java
@@ -56,8 +56,8 @@ public class BrokerLoadData {
     private double msgThroughputOut;  // bytes/sec
     private double msgRateIn; // messages/sec
     private double msgRateOut; // messages/sec
-    private int bundleCount;
-    private int topics;
+    private long bundleCount;
+    private long topics;
 
     // Load data features computed from the above resources.
     private double maxResourceUsage; // max of resource usages
@@ -115,8 +115,8 @@ public void update(final SystemResourceUsage usage,
                        double msgThroughputOut,
                        double msgRateIn,
                        double msgRateOut,
-                       int bundleCount,
-                       int topics,
+                       long bundleCount,
+                       long topics,
                        ServiceConfiguration conf) {
         updateSystemResourceUsage(usage.cpu, usage.memory, usage.directMemory, usage.bandwidthIn, usage.bandwidthOut);
         this.msgThroughputIn = msgThroughputIn;

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java
@@ -183,7 +183,7 @@ public synchronized void updateStats(
                         topicStatsStream.endObject();
                     });
 
-                    brokerStats.bundleCount += (int) bundles.size();
+                    brokerStats.bundleCount += bundles.size();
                     brokerStats.producerCount += nsStats.producerCount;
                     brokerStats.replicatorCount += nsStats.replicatorCount;
                     brokerStats.subsCount += nsStats.subsCount;

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -2205,7 +2205,7 @@ public void updateRates(NamespaceStats nsStats, NamespaceBundleStats bundleStats
 
         // Start subscription stats
         topicStatsStream.startObject("subscriptions");
-        nsStats.subsCount += (int) (subscriptions.size());
+        nsStats.subsCount += subscriptions.size();
 
         subscriptions.forEach((subscriptionName, subscription) -> {
             double subMsgRateOut = 0;