From 127b632421a5d8c3d069593576916154fefd6f12 Mon Sep 17 00:00:00 2001 From: Fangjin Yang Date: Tue, 11 Dec 2012 17:20:23 -0800 Subject: [PATCH] revert last commit --- .../java/com/metamx/druid/master/DruidMasterBalancer.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/server/src/main/java/com/metamx/druid/master/DruidMasterBalancer.java b/server/src/main/java/com/metamx/druid/master/DruidMasterBalancer.java index 41b0ae5379c..75d3534fef6 100644 --- a/server/src/main/java/com/metamx/druid/master/DruidMasterBalancer.java +++ b/server/src/main/java/com/metamx/druid/master/DruidMasterBalancer.java @@ -105,8 +105,8 @@ public class DruidMasterBalancer implements DruidMasterHelper continue; } - MinMaxPriorityQueue serversByPercentUsed = MinMaxPriorityQueue.orderedBy(percentUsedComparator) - .create(entry.getValue()); + TreeSet serversByPercentUsed = Sets.newTreeSet(percentUsedComparator); + serversByPercentUsed.addAll(entry.getValue()); if (serversByPercentUsed.size() <= 1) { log.info( @@ -116,8 +116,8 @@ public class DruidMasterBalancer implements DruidMasterHelper continue; } - ServerHolder highestPercentUsedServer = serversByPercentUsed.peekFirst(); - ServerHolder lowestPercentUsedServer = serversByPercentUsed.peekLast(); + ServerHolder highestPercentUsedServer = serversByPercentUsed.first(); + ServerHolder lowestPercentUsedServer = serversByPercentUsed.last(); analyzer.init(highestPercentUsedServer, lowestPercentUsedServer);