diff --git a/src/main/java/org/elasticsearch/river/routing/RiversRouter.java b/src/main/java/org/elasticsearch/river/routing/RiversRouter.java index 808e7b6aec8..5984b24dc82 100644 --- a/src/main/java/org/elasticsearch/river/routing/RiversRouter.java +++ b/src/main/java/org/elasticsearch/river/routing/RiversRouter.java @@ -241,6 +241,7 @@ public class RiversRouter extends AbstractLifecycleComponent imple it.remove(); routing.node(smallest); nodesToRivers.get(smallest).add(routing); + logger.debug("going to allocate river [{}] on node {}", routing.riverName().getName(), smallest); } }