diff --git a/core/src/main/java/kafka/autobalancer/model/AbstractInstanceUpdater.java b/core/src/main/java/kafka/autobalancer/model/AbstractInstanceUpdater.java index 3619081adc..d72746fb90 100644 --- a/core/src/main/java/kafka/autobalancer/model/AbstractInstanceUpdater.java +++ b/core/src/main/java/kafka/autobalancer/model/AbstractInstanceUpdater.java @@ -135,7 +135,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; @@ -145,7 +145,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;