Skip to content

Commit

Permalink
remove reduant code
Browse files Browse the repository at this point in the history
  • Loading branch information
qoo332001 committed May 22, 2023
1 parent dbae033 commit ebbc82b
Showing 1 changed file with 0 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -126,10 +126,6 @@ public static Map<Integer, Long> 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()
Expand Down

0 comments on commit ebbc82b

Please sign in to comment.