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 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();