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

Merge pull request #1327 from druid-io/more-coord-logs 

Additional coordinator logs to figure out when racy things might be hap...
This commit is contained in:
Xavier Léauté 2015-04-30 10:51:09 -07:00
parent 85335227fb a7f9bb1a1e
commit a2bde3af1b
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java
View File

@ -507,6 +507,7 @@ public class DruidCoordinator
} }
log.info("I am the leader of the coordinators, all must bow!"); log.info("I am the leader of the coordinators, all must bow!");
log.info("Starting coordination in [%s]", config.getCoordinatorStartDelay());
try { try {
leaderCounter++; leaderCounter++;
leader = true; leader = true;

4
server/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorSegmentInfoLoader.java
View File

@ -38,6 +38,8 @@ public class DruidCoordinatorSegmentInfoLoader implements DruidCoordinatorHelper
@Override @Override
public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params) public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params)
{ {
log.info("Starting coordination. Getting available segments.");
// Display info about all available segments // Display info about all available segments
final Set<DataSegment> availableSegments = coordinator.getOrderedAvailableDataSegments(); final Set<DataSegment> availableSegments = coordinator.getOrderedAvailableDataSegments();
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
@ -47,6 +49,8 @@ public class DruidCoordinatorSegmentInfoLoader implements DruidCoordinatorHelper
} }
} }
log.info("Found [%,d] available segments.", availableSegments.size());
return params.buildFromExisting() return params.buildFromExisting()
.withAvailableSegments(availableSegments) .withAvailableSegments(availableSegments)
.build(); .build();