[fix][sec] implicit narrowing conversion in compound assignment (apac…

…he#22074)
Technoboy- · Apr 1, 2024 · 9a43ab0 · 9a43ab0
1 parent 5ef60ed
commit 9a43ab0
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/...ent-admin-api/src/main/java/org/apache/pulsar/common/policies/data/SubscriptionStats.java b/...ent-admin-api/src/main/java/org/apache/pulsar/common/policies/data/SubscriptionStats.java
@@ -46,7 +46,7 @@ public interface SubscriptionStats {
     double getMessageAckRate();
 
     /** Chunked message dispatch rate. */
-    int getChunkedMessageRate();
+    double getChunkedMessageRate();
 
     /** Number of entries in the subscription backlog. */
     long getMsgBacklog();

diff --git a/...mon/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java b/...mon/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java
@@ -54,7 +54,7 @@ public class SubscriptionStatsImpl implements SubscriptionStats {
     public double messageAckRate;
 
     /** Chunked message dispatch rate. */
-    public int chunkedMessageRate;
+    public double chunkedMessageRate;
 
     /** Number of entries in the subscription backlog. */
     public long msgBacklog;

diff --git a/...ar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LocalBrokerData.java b/...ar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LocalBrokerData.java
@@ -66,7 +66,7 @@ public class LocalBrokerData implements LoadManagerReport {
     // The stats given in the most recent invocation of update.
     private Map<String, NamespaceBundleStats> lastStats;
 
-    private int numTopics;
+    private long numTopics;
     private int numBundles;
     private int numConsumers;
     private int numProducers;
@@ -202,7 +202,7 @@ private void updateBundleData(final Map<String, NamespaceBundleStats> bundleStat
         msgRateOut = 0;
         msgThroughputIn = 0;
         msgThroughputOut = 0;
-        int totalNumTopics = 0;
+        long totalNumTopics = 0;
         int totalNumBundles = 0;
         int totalNumConsumers = 0;
         int totalNumProducers = 0;