Repository: apex-core Updated Branches: refs/heads/master 3c503a91f -> 8b55fbe91
APEXCORE-513 Reducing the log level for node reports Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/9e3940fd Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/9e3940fd Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/9e3940fd Branch: refs/heads/master Commit: 9e3940fdc1e6a75f9a092c531bffaa2ee9c562f2 Parents: 65a721f Author: sandeshh <[email protected]> Authored: Tue Aug 30 14:47:59 2016 -0700 Committer: sandeshh <[email protected]> Committed: Tue Aug 30 20:46:40 2016 -0700 ---------------------------------------------------------------------- .../java/com/datatorrent/stram/ResourceRequestHandler.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/9e3940fd/engine/src/main/java/com/datatorrent/stram/ResourceRequestHandler.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/ResourceRequestHandler.java b/engine/src/main/java/com/datatorrent/stram/ResourceRequestHandler.java index 6ecc7c5..c56f64f 100644 --- a/engine/src/main/java/com/datatorrent/stram/ResourceRequestHandler.java +++ b/engine/src/main/java/com/datatorrent/stram/ResourceRequestHandler.java @@ -153,11 +153,9 @@ public class ResourceRequestHandler */ public void updateNodeReports(List<NodeReport> nodeReports) { - // LOG.debug("Got {} updated node reports.", nodeReports.size()); for (NodeReport nr : nodeReports) { - StringBuilder sb = new StringBuilder(); - sb.append("rackName=").append(nr.getRackName()).append(",nodeid=").append(nr.getNodeId()).append(",numContainers=").append(nr.getNumContainers()).append(",capability=").append(nr.getCapability()).append("used=").append(nr.getUsed()).append("state=").append(nr.getNodeState()); - LOG.info("Node report: " + sb); + + LOG.debug("Node report: rackName={}, nodeid={}, numContainers={}, capability={}, used={}, state={}", nr.getRackName(), nr.getNodeId(), nr.getNumContainers(), nr.getCapability(), nr.getUsed(), nr.getNodeState()); nodeReportMap.put(nr.getNodeId().getHost(), nr); nodeToRack.put(nr.getNodeId().getHost(), nr.getRackName()); }
