fix(auto_balancer): fix mistakenly reused reference (#2104)

Signed-off-by: Shichao Nie <niesc@automq.com>
AutoMQ · Oct 30, 2024 · 33e0be0 · 33e0be0
1 parent 8987499
commit 33e0be0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/kafka/autobalancer/model/AbstractInstanceUpdater.java b/core/src/main/java/kafka/autobalancer/model/AbstractInstanceUpdater.java
@@ -146,7 +146,7 @@ public void setMetricsOutOfDate(boolean metricsOutOfDate) {
         public void addLoad(byte resource, Load load) {
             this.loads.compute(resource, (k, v) -> {
                 if (v == null) {
-                    return load;
+                    return new Load(load);
                 }
                 v.add(load);
                 return v;
@@ -156,7 +156,7 @@ public void addLoad(byte resource, Load load) {
         public void reduceLoad(byte resource, Load load) {
             this.loads.compute(resource, (k, v) -> {
                 if (v == null) {
-                    return load;
+                    return new Load(load);
                 }
                 v.reduceValue(load);
                 return v;