Additional coordinator logs to figure out when racey things might be …

…happening
apache · Apr 30, 2015 · a7f9bb1 · a7f9bb1
1 parent 40121bc
commit a7f9bb1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java b/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java
@@ -507,6 +507,7 @@ private void becomeLeader()
       }
 
       log.info("I am the leader of the coordinators, all must bow!");
+      log.info("Starting coordination in [%s]", config.getCoordinatorStartDelay());
       try {
         leaderCounter++;
         leader = true;

diff --git a/...r/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorSegmentInfoLoader.java b/...r/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorSegmentInfoLoader.java
@@ -38,6 +38,8 @@ public DruidCoordinatorSegmentInfoLoader(DruidCoordinator coordinator)
   @Override
   public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params)
   {
+    log.info("Starting coordination. Getting available segments.");
+
     // Display info about all available segments
     final Set<DataSegment> availableSegments = coordinator.getOrderedAvailableDataSegments();
     if (log.isDebugEnabled()) {
@@ -47,6 +49,8 @@ public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params)
       }
     }
 
+    log.info("Found [%,d] available segments.", availableSegments.size());
+
     return params.buildFromExisting()
                  .withAvailableSegments(availableSegments)
                  .build();