Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

1) whitespace

This commit is contained in:
Eric Tschetter 2013-02-01 16:21:26 -06:00
parent 5f2c3cec1b
commit 1a9edbebd3
1 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
server/src/main/java/com/metamx/druid/master/DruidMasterBalancer.java
View File

@ -91,11 +91,7 @@ public class DruidMasterBalancer implements DruidMasterHelper
if (!currentlyMovingSegments.get(tier).isEmpty()) { if (!currentlyMovingSegments.get(tier).isEmpty()) {
reduceLifetimes(tier); reduceLifetimes(tier);
log.info( log.info("[%s]: Still waiting on %,d segments to be moved", tier, currentlyMovingSegments.size());
"[%s]: Still waiting on %,d segments to be moved",
tier,
currentlyMovingSegments.size()
);
continue; continue;
} }
@ -104,8 +100,7 @@ public class DruidMasterBalancer implements DruidMasterHelper
if (serversByPercentUsed.size() <= 1) { if (serversByPercentUsed.size() <= 1) {
log.info( log.info(
"[%s]: No unique values found for highest and lowest percent used servers: nothing to balance", "[%s]: No unique values found for highest and lowest percent used servers: nothing to balance", tier
tier
); );
continue; continue;
} }
@ -169,12 +164,7 @@ public class DruidMasterBalancer implements DruidMasterHelper
if (!toPeon.getSegmentsToLoad().contains(segmentToMove) && if (!toPeon.getSegmentsToLoad().contains(segmentToMove) &&
(server.getSegment(segmentName) == null) && (server.getSegment(segmentName) == null) &&
new ServerHolder(server, toPeon).getAvailableSize() > segmentToMove.getSize()) { new ServerHolder(server, toPeon).getAvailableSize() > segmentToMove.getSize()) {
log.info( log.info("Moving [%s] from [%s] to [%s]", segmentName, fromServer, toServer);
"Moving [%s] from [%s] to [%s]",
segmentName,
fromServer,
toServer
);
try { try {
master.moveSegment( master.moveSegment(
fromServer, fromServer,