Move frequent info logging to debug level

This commit is contained in:
Shalin Shekhar Mangar 2017-05-15 14:32:13 +05:30
parent 5d7069bd52
commit 1f3f50745a
2 changed files with 3 additions and 3 deletions

View File

@ -172,7 +172,7 @@ public class NodeAddedTrigger implements AutoScaling.Trigger<NodeAddedTrigger.No
ZkStateReader reader = container.getZkController().getZkStateReader(); ZkStateReader reader = container.getZkController().getZkStateReader();
Set<String> newLiveNodes = reader.getClusterState().getLiveNodes(); Set<String> newLiveNodes = reader.getClusterState().getLiveNodes();
log.info("Found livenodes: " + newLiveNodes); log.debug("Found livenodes: {}", newLiveNodes);
if (lastLiveNodes == null) { if (lastLiveNodes == null) {
lastLiveNodes = newLiveNodes; lastLiveNodes = newLiveNodes;
return; return;

View File

@ -77,7 +77,7 @@ public class NodeLostTrigger implements AutoScaling.Trigger<NodeLostTrigger.Node
actions = Collections.emptyList(); actions = Collections.emptyList();
} }
lastLiveNodes = container.getZkController().getZkStateReader().getClusterState().getLiveNodes(); lastLiveNodes = container.getZkController().getZkStateReader().getClusterState().getLiveNodes();
log.info("Initial livenodes: " + lastLiveNodes); log.debug("Initial livenodes: {}", lastLiveNodes);
this.enabled = (boolean) properties.getOrDefault("enabled", true); this.enabled = (boolean) properties.getOrDefault("enabled", true);
this.waitForSecond = ((Long) properties.getOrDefault("waitFor", -1L)).intValue(); this.waitForSecond = ((Long) properties.getOrDefault("waitFor", -1L)).intValue();
this.eventType = AutoScaling.EventType.valueOf(properties.get("event").toString().toUpperCase(Locale.ROOT)); this.eventType = AutoScaling.EventType.valueOf(properties.get("event").toString().toUpperCase(Locale.ROOT));
@ -173,7 +173,7 @@ public class NodeLostTrigger implements AutoScaling.Trigger<NodeLostTrigger.Node
ZkStateReader reader = container.getZkController().getZkStateReader(); ZkStateReader reader = container.getZkController().getZkStateReader();
Set<String> newLiveNodes = reader.getClusterState().getLiveNodes(); Set<String> newLiveNodes = reader.getClusterState().getLiveNodes();
log.info("Found livenodes: " + newLiveNodes); log.debug("Found livenodes: {}", newLiveNodes);
// have any nodes that we were tracking been added to the cluster? // have any nodes that we were tracking been added to the cluster?
// if so, remove them from the tracking map // if so, remove them from the tracking map