From ebbc82b8863893c88c06f812cc599e05c3959dbc Mon Sep 17 00:00:00 2001 From: qoo332001 Date: Mon, 22 May 2023 23:10:15 +0800 Subject: [PATCH] remove reduant code --- .../src/main/java/org/astraea/common/cost/MigrationCost.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/common/src/main/java/org/astraea/common/cost/MigrationCost.java b/common/src/main/java/org/astraea/common/cost/MigrationCost.java index 46df3bb27c..5083fced65 100644 --- a/common/src/main/java/org/astraea/common/cost/MigrationCost.java +++ b/common/src/main/java/org/astraea/common/cost/MigrationCost.java @@ -126,10 +126,6 @@ public static Map brokerMigrationSecond( Map.Entry::getKey, brokerSize -> brokerSize.getValue() / brokerOutRate.get(brokerSize.getKey()).orElse(0))); - brokerInRate.forEach( - (b, rate) -> System.out.println("broker: " + b + " inRate: " + rate.orElse(0))); - brokerOutRate.forEach( - (b, rate) -> System.out.println("broker: " + b + " OutRate: " + rate.orElse(0))); return Stream.concat(before.nodes().stream(), after.nodes().stream()) .map(NodeInfo::id) .distinct()