From a7f9bb1a1ea5540a64c894472a6ffa223b3db3b5 Mon Sep 17 00:00:00 2001
From: fjy <fangjinyang@gmail.com>
Date: Thu, 30 Apr 2015 08:26:52 -0700
Subject: [PATCH] Additional coordinator logs to figure out when racey things
 might be happening

---
 .../java/io/druid/server/coordinator/DruidCoordinator.java    | 1 +
 .../coordinator/helper/DruidCoordinatorSegmentInfoLoader.java | 4 ++++
 2 files changed, 5 insertions(+)

diff --git a/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java b/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java
index c82a92223f8..d1398bffa18 100644
--- 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 @@ public class DruidCoordinator
       }
 
       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/server/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorSegmentInfoLoader.java b/server/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorSegmentInfoLoader.java
index 68ac59d1471..8b71342c949 100644
--- a/server/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorSegmentInfoLoader.java
+++ b/server/src/main/java/io/druid/server/coordinator/helper/DruidCoordinatorSegmentInfoLoader.java
@@ -38,6 +38,8 @@ public class DruidCoordinatorSegmentInfoLoader implements DruidCoordinatorHelper
   @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 class DruidCoordinatorSegmentInfoLoader implements DruidCoordinatorHelper
       }
     }
 
+    log.info("Found [%,d] available segments.", availableSegments.size());
+
     return params.buildFromExisting()
                  .withAvailableSegments(availableSegments)
                  .build();